|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--com.ibm.dse.base.DSENotifier | +--com.ibm.dse.base.Service | +--com.ibm.dse.services.mq.MQConnection
This class maps a MQ connection to a MQManager with the defined queues.
Field Summary | |
protected QueueListener |
aQueueListener
|
java.lang.String |
channelQName
The Channel Reply Queue name. |
static java.lang.String |
COMPID
|
static java.lang.String |
DATA
|
static java.lang.String |
DEADLETTERQ
DeadLetter Queue representation field. |
java.lang.String |
deadLetterQName
The DeadLetter Queue name. |
MqDeadLetterQueueThread |
deadLetterQueueThread
MqDeadLetterQueueThread field. |
static java.lang.reflect.Field |
encode
|
protected boolean |
isDeadLetterThreadAlive
|
static java.lang.String |
LISTEN_THREAD
Listen Thread representation field. |
java.lang.String |
QMgrName
The QueueManager name. |
static java.lang.String |
QMGRNAME
|
static java.lang.String |
QUEUE
|
Semaphore |
receiveSem
The receiver semaphore. |
static java.lang.String |
REPLYTOQ
|
java.lang.String |
ReplyToQName
The Reply Queue name. |
static java.lang.String |
RESET
|
static java.lang.String |
SENDTOQ
|
java.lang.String |
SendToQName
The Send Queue name. |
Fields inherited from class com.ibm.dse.base.Service |
externalizer |
Fields inherited from class com.ibm.dse.base.DSENotifier |
handlersList,
name |
Fields inherited from interface com.ibm.dse.services.comms.CommonCommunicationsService |
CLOSED,
DATA,
DATASENT,
ERROR,
OPENED,
RECEIVERC,
TIMEOUT |
Constructor Summary | |
MQConnection()
This class is used to maintains a connection to a MQManager with the defined queues. |
|
MQConnection(java.lang.String aName)
This class is used to maintains a connection to a MQManager with the defined queues. |
Method Summary | |
void |
addQueueListener(QueueListener newListener)
Adds a listener to Queue |
void |
ccClose()
Closes the communications chanel. |
void |
ccOpen()
Opens the communications channel. |
CCMessage |
ccReceiveData(long aTimeout)
Reads the data that has been received.If the data is not ready, it waits for the timeout. |
void |
ccSendData(java.lang.String aString)
Sends a Data through the communications channel. |
CCMessage |
ccSendReceive(java.lang.String aString,
long aTimeout)
Sends a String to communication services, and waits for a Timeout to receive the data. |
void |
closeConnection()
Disconnects from queue manager, and removes the used queues. |
void |
disconnectQueueManager()
Disconnects the queueManagers related to send, receive,channel and DeadLetter operations. |
void |
establishConnection()
Establishes a connection with a MQManager, and opens the send and receive queues. |
void |
fireMessageReceived(QueueEvent event)
Supports listener events. |
java.lang.String |
getApplicationName()
Gets the applicationName property (java.lang.String) value. |
boolean |
getAutomaticConnectionEstablishment()
Gets the automaticSessionEstablishment property (java.lang.Boolean) value. |
java.lang.String |
getCcClosedEventName()
Returns the name of the closed event. |
java.lang.String |
getCcDataReceivedEventName()
Returns the name of the errorReceived event. |
java.lang.String |
getCcErrorReceivedEventName()
Returns the name of the errorReceived event. |
java.lang.String |
getCcOpenedEventName()
Returns the name of the opened event. |
java.lang.String |
getchannelName()
Gets the channel property (java.lang.String) value. |
int |
getChannelStatus(java.lang.String channelName)
Returns the channel status from the inquired channel. |
int |
getCharSet()
Gets the charSet property value. |
java.lang.String |
getDeadLetterQName()
Gets the deadLetterQName property (java.lang.String) value. |
int |
getEncoding()
Gets the encoding property value. |
int |
getEstablishConnectionRetries()
Gets the establishConnectionRetries property (int) value. |
java.lang.String |
getFormat()
Gets the format property value. |
com.ibm.mq.MQMessage |
getFromDeadLetterQueue()
Gets a message from the DeadLetterQueue. |
com.ibm.mq.MQMessage |
getFromGetReplyQueue()
Gets a message from the replyqueue. |
com.ibm.mq.MQMessage |
getFromGetReplyQueue(byte[] aCorrelationId)
Gets a message with a correlation identifier(aCorrelationId) from the replyqueue . |
int |
getGetMessageOptionsOptions()
Gets the get message options (int) value. |
java.lang.String |
getHostName()
Gets the hostName property (java.lang.String) value. |
boolean |
getInUse()
Gets the inUse property (boolean) value. |
boolean |
getMatchCorrelationId()
Gets the matchCorrelationId property (boolean) value. |
int |
getMessageType()
Gets the messageType property value. |
int |
getPersistence()
Gets the persistence property value. |
int |
getPortNumber()
Gets the port number(int) value. |
int |
getPutMessageOptionsOptions()
Gets the put message options (int) value. |
java.lang.String |
getQmgrReply()
Gets the QmgrReply property value. |
java.lang.String |
getQueueManagerName()
Gets the queue manager name (String) value. |
java.lang.String |
getReplyToQName()
Gets the replyToQName property (java.lang.String) value. |
int |
getReplyToQOpenOptions()
Gets the ReplyToQ open options (int) value. |
java.lang.String |
getSendToQName()
Gets the sendToQName property (java.lang.String) value. |
int |
getSendToQOpenOptions()
Gets the SendToQ open options (int) value. |
boolean |
getServer()
Gets the server property (java.lang.Boolean) value. |
java.lang.String |
getStatus()
Gets the connection status value. |
boolean |
getSynchronousMode()
Gets the synchronousMode property (boolean) value. |
int |
getTimeBetweenRetries()
Gets the timeBetweenRetries property (int) value. |
int |
getTimeout()
Gets the timeout property value. |
java.lang.String |
getUserId()
Gets the userId property value. |
protected void |
initializeCounter()
Sets the EstablishConnectionSessionCounter property to its default value. |
java.lang.Object |
initializeFrom(Tag aTag)
Actualizes all attributes that are defined in SGML files. |
void |
initInstance()
Initiates all handlers that have a default treatment. |
void |
initManagers()
Initiates all handlers that have a default treatment. |
boolean |
isCloseMessage(java.lang.Object aMessage)
Checks if close Message has been received. |
boolean |
isDeadLetterQReset()
Checks if DeadLetter queue manager is open. |
boolean |
isFree()
Returns if the session is free |
boolean |
isOffline()
Returns if the session is offline |
boolean |
isResetStatus()
Checks if queue managers are open. |
byte[] |
putToPutSendQueue(com.ibm.mq.MQMessage aMessage)
Puts aMessage(MQMessage) in the putSendQueue and returns the correlation identifier for this message. |
byte[] |
putToPutSendQueue(java.lang.String aData)
Puts a MQMessage in the putSendQueue, creates data aData and message default options,and returns the correlation ID of this message, |
java.lang.Object |
receive(byte[] aCorrelationId)
Performs the receive method. |
java.lang.Object |
receive(byte[] aCorrelationId,
long aTimeout)
Performs the receive method. |
void |
receiveFromDeadLetterQueue()
Performs the receive method, which is used by listen threads when it is working in asynchronous mode |
void |
removeQueueListener(QueueListener newListener)
Removes queue listener. |
int |
resetChannel(java.lang.String channelName)
Resets the message sequence number for a channel. |
int |
resetChannel(java.lang.String channelName,
int msgSeqNumber)
Resets the message sequence number for a channel. |
DSECCException |
returnException(java.lang.Exception e)
Maps the MQException to the DSECCException |
java.lang.String |
returnStringFromMessage(java.lang.Object aMessage)
Obtains the msgText(String) from a MQMessage. |
void |
run()
Run method. |
byte[] |
send(Context aContext,
FormatElement aFormat)
Performs the send method. |
byte[] |
send(Context aContext,
java.lang.String aFormatName)
Performs the send method. |
byte[] |
send(java.lang.Object inputMessage)
Performs the send method. |
byte[] |
send(java.lang.String inputMessage)
Performs the send method. |
void |
setApplicationName(java.lang.String newApplicationName)
Sets the applicationName property (java.lang.String) value. |
void |
setAutomaticConnectionEstablishment(boolean automaticEstablishment)
Sets the automaticConnectionEstablishment property (boolean) value. |
void |
setChannelName(java.lang.String chname)
Sets the Channel property (java.lang.String) value. |
void |
setCharSet(int newCharSet)
Sets the charSet property value. |
void |
setDeadLetterMessageOptionsMatchOptions(int options)
Sets DeadLetterQueue match Options property (MQGetMessageOptions) value. |
void |
setDeadLetterMessageOptionsWaitInterval(int options)
Sets DeadLetterQueue option waitInterval property (MQGetMessageOptions) value. |
void |
setDeadLetterQName(java.lang.String dlname)
Sets the deadLetterQName property (java.lang.String) value. |
void |
setEncoding(int newEncoding)
Sets the encoding property value. |
void |
setEstablishConnectionRetries(int establishConnectionRetries)
Sets the establishSessionRetries property (int) value. |
void |
setFormat(java.lang.String newFormat)
Sets the format property (java.lang.String) value. |
void |
setGetMessageOptionsMatchOptions(int options)
Sets GetMessageOptions match Options property (MQGetMessageOptions) value. |
void |
setGetMessageOptionsOptions(int options)
Sets GetMessageOptions Options field property (int) value. |
void |
setGetMessageOptionsWaitInterval(int options)
Sets GetMessageOptions WaitInterval field property (MQGetMessageOptions) value. |
void |
setHostName(java.lang.String hname)
Sets the Host name property (java.lang.String) value. |
void |
setInUse(boolean anInUse)
Sets the inUse property (boolean) value. |
void |
setMatchCorrelation(boolean newValue)
Sets the matchCorrelation property (boolean) value. |
void |
setMessageType(int newMessageType)
Sets the messageType property value. |
void |
setPersistence(int newPersistence)
Sets the persistence property value. |
void |
setPortNumber(int pnum)
Sets the Port number property (int) value. |
void |
setPutMessageOptionsOptions(int options)
Sets PutMessageOptions Options field property (int) value. |
void |
setQmgrName(java.lang.String qmgrname)
Sets the QMgrName property (java.lang.String) value. |
void |
setQmgrReply(java.lang.String newQmgrReply)
Sets the QmgrReply property (java.lang.String) value. |
void |
setReplyQName(java.lang.String rqname)
Sets the ReplyToQName property (java.lang.String) value. |
void |
setReplyToQOpenOptions(int options)
Sets ReplyToQOpenOptions field property (int) value. |
void |
setSendQName(java.lang.String sqname)
Sets the SendToQName property (java.lang.String) value. |
void |
setSendToQOpenOptions(int options)
Sets SendToQOpenOptions field property (int) value. |
void |
setServer(boolean aBoolean)
Sets the server property (boolean) value. |
void |
setSynchronousMode(boolean aSynchronousMode)
Sets the synchronousMode property (boolean) value. |
void |
setTimeBetweenRetries(int timeBetweenRetries)
Sets the timeBetweenRetries property (int) value. |
void |
setTimeout(int newTimeout)
Sets the timeout property value. |
void |
setUserId(java.lang.String newUserId)
Sets the userId property (java.lang.String) value. |
int |
startChannel(java.lang.String channelName)
Starts the specified channel. |
int |
stopChannel(java.lang.String channelName)
Stops the specified channel. |
void |
terminate()
Terminates the conversation. |
java.lang.String |
toString()
Returns a visual representation of this object. |
Methods inherited from class com.ibm.dse.base.Service |
externalizer,
getExternalizer,
getTagName,
readExternal,
readExternal,
readObject,
removeExternal,
setExternalizer,
toStrings,
toTags,
writeExternal,
writeExternal |
Methods inherited from class com.ibm.dse.base.DSENotifier |
addHandler,
getHandlersList,
getName,
removeHandler,
setName,
signalEvent,
signalEvent,
signalEvent |
Methods inherited from class java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
wait,
wait,
wait |
Field Detail |
public Semaphore receiveSem
public static final java.lang.String LISTEN_THREAD
public static final java.lang.String DEADLETTERQ
protected transient QueueListener aQueueListener
public java.lang.String QMgrName
public java.lang.String SendToQName
public java.lang.String ReplyToQName
public java.lang.String channelQName
public java.lang.String deadLetterQName
public MqDeadLetterQueueThread deadLetterQueueThread
public static final java.lang.String RESET
public static final java.lang.String DATA
public static final java.lang.String QUEUE
public static final java.lang.String QMGRNAME
public static final java.lang.String SENDTOQ
public static final java.lang.String REPLYTOQ
public static java.lang.reflect.Field encode
public static final java.lang.String COMPID
protected boolean isDeadLetterThreadAlive
Constructor Detail |
public MQConnection()
public MQConnection(java.lang.String aName) throws java.io.IOException
aName
- java.lang.StringMethod Detail |
public void addQueueListener(QueueListener newListener)
newListener
- com.ibm.dse.services.mq.QueueListenerpublic void ccClose() throws DSECCException
Closes the communications chanel. It returns control immediately.If the communications channel is started correctly, the event ChannelClosed is signaled.
aString
- java.lang.Stringpublic void ccOpen() throws DSECCException
Opens the communications channel. It returns control immediately.If the communications channel is started correctly, the event ChannelOpened is signaled.
public CCMessage ccReceiveData(long aTimeout) throws DSECCException
Reads the data that has been received.If the data is not ready, it waits for the timeout.
aTimeout
- longpublic void ccSendData(java.lang.String aString) throws DSECCException
Sends a Data through the communications channel. It returns control immediately. When a response is received, two events might be signaled: DataReceived event (in case of data received) or ErrorReceived(in case of error).
aString
- java.lang.Stringpublic CCMessage ccSendReceive(java.lang.String aString, long aTimeout) throws DSECCException
Sends a String to communication services, and waits for a Timeout to receive the data.
aString
- java.lang.StringaTimeout
- longpublic void closeConnection() throws com.ibm.mq.MQException
Disconnects from queue manager, and removes the used queues.
public void disconnectQueueManager() throws com.ibm.mq.MQException
Disconnects the queueManagers related to send, receive,channel and DeadLetter operations.
public void establishConnection() throws com.ibm.mq.MQException
Establishes a connection with a MQManager, and opens the send and receive queues.
public void fireMessageReceived(QueueEvent event)
Supports listener events.
event
- com.ibm.dse.services.mq.QueueEventpublic java.lang.String getApplicationName()
Gets the applicationName property (java.lang.String) value.
setApplicationName(java.lang.String)
public boolean getAutomaticConnectionEstablishment()
Gets the automaticSessionEstablishment property (java.lang.Boolean) value.
#setAutomaticSessionEstablishment
public java.lang.String getCcClosedEventName()
Returns the name of the closed event.
public java.lang.String getCcDataReceivedEventName()
Returns the name of the errorReceived event.
public java.lang.String getCcErrorReceivedEventName()
Returns the name of the errorReceived event.
public java.lang.String getCcOpenedEventName()
Returns the name of the opened event.
public java.lang.String getchannelName()
public int getChannelStatus(java.lang.String channelName) throws com.ibm.mq.MQException
Returns the channel status from the inquired channel.
channelName
- The name of the inquired channel.public int getCharSet()
Gets the charSet property value.
setCharSet(int)
public java.lang.String getDeadLetterQName()
public int getEncoding()
Gets the encoding property value.
setEncoding(int)
public int getEstablishConnectionRetries()
Gets the establishConnectionRetries property (int) value. If it is negative, it means that the session retries to establish forever, otherwise this property says how many times it will establish itself.
setEstablishConnectionRetries(int)
public java.lang.String getFormat()
Gets the format property value.
setFormat(java.lang.String)
public com.ibm.mq.MQMessage getFromDeadLetterQueue() throws com.ibm.mq.MQException
Gets a message from the DeadLetterQueue.
public com.ibm.mq.MQMessage getFromGetReplyQueue() throws com.ibm.mq.MQException, java.io.IOException
Gets a message from the replyqueue.
public com.ibm.mq.MQMessage getFromGetReplyQueue(byte[] aCorrelationId) throws com.ibm.mq.MQException, java.io.IOException
Gets a message with a correlation identifier(aCorrelationId) from the replyqueue .
public int getGetMessageOptionsOptions()
Gets the get message options (int) value.
public java.lang.String getHostName()
public boolean getInUse()
Gets the inUse property (boolean) value. If true, if this instance is in use.
setInUse(boolean)
public boolean getMatchCorrelationId()
Gets the matchCorrelationId property (boolean) value. If true,on the receive method, the service matches the message correlation identifier.If false message identifier is used as selection match criteria.
#setmatchCorrelationId
public int getMessageType()
Gets the messageType property value.
setMessageType(int)
public int getPersistence()
Gets the persistence property value.
setPersistence(int)
public int getPortNumber()
Gets the port number(int) value.
public int getPutMessageOptionsOptions()
Gets the put message options (int) value.
public java.lang.String getQmgrReply()
Gets the QmgrReply property value.
setQmgrReply(java.lang.String)
public java.lang.String getQueueManagerName()
Gets the queue manager name (String) value.
public java.lang.String getReplyToQName()
public int getReplyToQOpenOptions()
Gets the ReplyToQ open options (int) value.
public java.lang.String getSendToQName()
public int getSendToQOpenOptions()
Gets the SendToQ open options (int) value.
public boolean getServer()
Gets the server property (java.lang.Boolean) value.
public java.lang.String getStatus()
Gets the connection status value. Possible values are:
#setSessionStatus
public boolean getSynchronousMode()
Gets the synchronousMode property (boolean) value. If the synchronousMode is true, no event or Java events are signaled.
#setConfirmMode
public int getTimeBetweenRetries()
setTimeBetweenRetries(int)
public int getTimeout()
Gets the timeout property value.
setTimeout(int)
public java.lang.String getUserId()
Gets the userId property value.
setUserId(java.lang.String)
protected void initializeCounter()
public java.lang.Object initializeFrom(Tag aTag) throws java.io.IOException, DSEException
Actualizes all attributes that are defined in SGML files. If automaticConversationEstablishment is true the establishConversation is issued.
aTag
- com.ibm.dse.base.Tagpublic void initInstance() throws DSECCException, DSEInvalidArgumentException
Initiates all handlers that have a default treatment. It also creates the listenThread.
public void initManagers() throws com.ibm.mq.MQException
Initiates all handlers that have a default treatment. It also creates the listenThread.
public boolean isCloseMessage(java.lang.Object aMessage)
Checks if close Message has been received.
public boolean isDeadLetterQReset()
Checks if DeadLetter queue manager is open.
public boolean isFree()
Returns if the session is free
public boolean isOffline()
Returns if the session is offline
public boolean isResetStatus()
Checks if queue managers are open.
public byte[] putToPutSendQueue(com.ibm.mq.MQMessage aMessage) throws com.ibm.mq.MQException
Puts aMessage(MQMessage) in the putSendQueue and returns the correlation identifier for this message.
aMessage
- The message to put into the send queue.public byte[] putToPutSendQueue(java.lang.String aData) throws com.ibm.mq.MQException, java.io.IOException
Puts a MQMessage in the putSendQueue, creates data aData and message default options,and returns the correlation ID of this message,
aMessage
- The message to put into the send queue.public java.lang.Object receive(byte[] aCorrelationId) throws com.ibm.mq.MQException, java.io.IOException
public java.lang.Object receive(byte[] aCorrelationId, long aTimeout) throws com.ibm.mq.MQException, java.io.IOException
correlationId(byte[]).
- The message correlation identifier to get the correct message.timeout(long).
- public void receiveFromDeadLetterQueue()
Performs the receive method, which is used by listen threads when it is working in asynchronous mode
public void removeQueueListener(QueueListener newListener)
newListener
- com.ibm.dse.services.mq.QueueListenerpublic int resetChannel(java.lang.String channelName) throws com.ibm.mq.MQException
Resets the message sequence number for a channel.
channelName
- The name of the channel to be reset.public int resetChannel(java.lang.String channelName, int msgSeqNumber) throws com.ibm.mq.MQException
Resets the message sequence number for a channel.
channelName
- The name of the channel to be reset.msgSeqNumber.
- Spcifies the new sequence number.public DSECCException returnException(java.lang.Exception e)
Maps the MQException to the DSECCException
public java.lang.String returnStringFromMessage(java.lang.Object aMessage) throws DSECCException
public void run()
public byte[] send(Context aContext, FormatElement aFormat) throws DSEException, com.ibm.mq.MQException, java.io.IOException
Performs the send method.
aContext
- com.ibm.dse.base.Context. The context element object.aFormat
- com.ibm.dse.base.FormatElement.The format element object.public byte[] send(Context aContext, java.lang.String aFormatName) throws DSEException, com.ibm.mq.MQException
Performs the send method.
aContext
- com.ibm.dse.base.Context.The format elemaFormatName
- java.lang.String.The format element name.public byte[] send(java.lang.Object inputMessage) throws com.ibm.mq.MQException
aString
- java.lang.Stringpublic byte[] send(java.lang.String inputMessage) throws com.ibm.mq.MQException, java.io.IOException
Performs the send method.
aString
- java.lang.Stringpublic void setApplicationName(java.lang.String newApplicationName)
newApplicationName
- java.lang.StringgetApplicationName()
public void setAutomaticConnectionEstablishment(boolean automaticEstablishment)
Sets the automaticConnectionEstablishment property (boolean) value.
automaticEstablishment
- The new value for the property.getAutomaticConnectionEstablishment()
public void setChannelName(java.lang.String chname)
The
- Channel(java.lang.String) property value.public void setCharSet(int newCharSet)
Sets the charSet property value.
newCharSet
- intgetCharSet()
public void setDeadLetterMessageOptionsMatchOptions(int options)
Sets DeadLetterQueue match Options property (MQGetMessageOptions) value.
options(int).
- The DeadLetter message matchOptions.public void setDeadLetterMessageOptionsWaitInterval(int options)
Sets DeadLetterQueue option waitInterval property (MQGetMessageOptions) value.
options(int).
- The waitInterval DeadLetter message option.public void setDeadLetterQName(java.lang.String dlname)
The
- deadLetterQName(java.lang.String) property value.public void setEncoding(int newEncoding)
Sets the encoding property value.
newEncoding
- intgetEncoding()
public void setEstablishConnectionRetries(int establishConnectionRetries)
establishSessionRetries
- The new value for the property.#getEstablishSessionRetries
public void setFormat(java.lang.String newFormat)
newFormat
- java.lang.Stringpublic void setGetMessageOptionsMatchOptions(int options)
Sets GetMessageOptions match Options property (MQGetMessageOptions) value.
options(int).
- The GetMessageOptions matchoptions.public void setGetMessageOptionsOptions(int options)
Sets GetMessageOptions Options field property (int) value.
options(int).
- The GetMessageOptions options.public void setGetMessageOptionsWaitInterval(int options)
Sets GetMessageOptions WaitInterval field property (MQGetMessageOptions) value.
options(int).
- The WaitInterval GetMessageOptions option.public void setHostName(java.lang.String hname)
The
- hostName(java.lang.String) property value.public void setInUse(boolean anInUse)
Sets the inUse property (boolean) value.
anInUse
- The new value for the property.getInUse()
public void setMatchCorrelation(boolean newValue)
Sets the matchCorrelation property (boolean) value.
newValue
- The new value for the property.#getmatchCorrelation
public void setMessageType(int newMessageType)
Sets the messageType property value.
newMessageType
- intpublic void setPersistence(int newPersistence)
Sets the persistence property value.
newPersistence
- intgetPersistence()
public void setPortNumber(int pnum)
The
- port(int) property value.public void setPutMessageOptionsOptions(int options)
Sets PutMessageOptions Options field property (int) value.
options(int).
- The PutMessageOptions options.public void setQmgrName(java.lang.String qmgrname)
The
- QMgrName(java.lang.String) property value.public void setQmgrReply(java.lang.String newQmgrReply)
newQmgrReply
- java.lang.Stringpublic void setReplyQName(java.lang.String rqname)
The
- replyToQName(java.lang.String) property value.public void setReplyToQOpenOptions(int options)
Sets ReplyToQOpenOptions field property (int) value.
options(int).
- The ReplyToQ open options.public void setSendQName(java.lang.String sqname)
The
- sendToQName(java.lang.String) property value.public void setSendToQOpenOptions(int options)
Sets SendToQOpenOptions field property (int) value.
options(int).
- The SendToQ open options.public void setServer(boolean aBoolean)
Sets the server property (boolean) value.
aBoolean.
- The new boolean value for the property.getAutomaticConnectionEstablishment()
public void setSynchronousMode(boolean aSynchronousMode)
Sets the synchronousMode property (boolean) value.
aSynchronousMode
- The new value for the property.getSynchronousMode()
public void setTimeBetweenRetries(int timeBetweenRetries)
timeBetweenRetries
- The new value for the property.getTimeBetweenRetries()
public void setTimeout(int newTimeout)
Sets the timeout property value.
newTimeout
- intgetTimeout()
public void setUserId(java.lang.String newUserId)
newUserId
- java.lang.Stringpublic int startChannel(java.lang.String channelName) throws com.ibm.mq.MQException
Starts the specified channel.
channelName
- The name of the channel to be started.public int stopChannel(java.lang.String channelName) throws com.ibm.mq.MQException
Stops the specified channel.
channelName
- The name of the channel to be stopped.public void terminate()
Terminates the conversation. This method terminates the internal thread and closes the conversation ABNORMALY, if required (if in RECEIVE state).
public java.lang.String toString()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |