|
IBM WebSphere Multichannel Bank Transformation Toolkit Javadoc | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.ibm.btt.base.BTTProcessorNotifier
com.ibm.btt.base.Service
com.ibm.btt.services.mq.MQConnection
public class MQConnection
This class maps an 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 Hashtable |
eventParameter
|
protected Hashtable |
eventParameterD
|
protected java.lang.String |
EXCEPTION
|
protected com.ibm.mq.MQGetMessageOptions |
gmo
|
protected boolean |
isDeadLetterThreadAlive
|
static java.lang.String |
LISTEN_THREAD
Listen Thread representation field. |
protected Hashtable |
messageQTable
|
protected Hashtable |
messageTable
|
java.lang.String |
QMgrName
The QueueManager name. |
static java.lang.String |
QMGRNAME
|
static java.lang.String |
QUEUE
|
protected int |
receiveReturnCode
|
Semaphore |
receiveSem
The receiver semaphore. |
java.lang.String |
ReplyDynamicQName
|
java.lang.String |
ReplyModelQName
|
protected boolean |
ReplyQueueAccessed
|
static java.lang.String |
REPLYTOQ
|
java.lang.String |
ReplyToQName
The Reply Queue name. |
protected com.ibm.mq.MQQueue |
ReplyToQueue
|
static java.lang.String |
RESET
|
java.lang.String |
SendDynamicQName
|
java.lang.String |
SendModelQName
|
protected boolean |
SendQueueAccessed
|
static java.lang.String |
SENDTOQ
|
java.lang.String |
SendToQName
The Send Queue name. |
protected com.ibm.mq.MQQueue |
SendToQueue
|
protected com.ibm.mq.MQMessage |
tempMqMessage
|
Fields inherited from class com.ibm.btt.base.Service |
---|
externalizer, name |
Fields inherited from class com.ibm.btt.base.BTTProcessorNotifier |
---|
handlersList |
Fields inherited from interface com.ibm.btt.services.comms.CommonCommunicationsService |
---|
CLOSED, DATASENT, ERROR, OPENED, RECEIVERC, TIMEOUT |
Constructor Summary | |
---|---|
MQConnection()
Maintains a connection to a MQManager with the defined queues. |
|
MQConnection(java.lang.String aName)
Maintains a connection to a MQManager with the defined queues. |
Method Summary | |
---|---|
void |
addQueueListener(QueueListener newListener)
Adds a listener to the queue. |
void |
ccClose()
Closes the communications channel and returns control immediately. |
void |
ccOpen()
Opens the communications chanel and returns control immediately. |
CCMessage |
ccReceiveData(long aTimeout)
Reads the data that has been received. |
void |
ccSendData(java.lang.String aString)
Sends the data through the communications channel and returns control immediately. |
CCMessage |
ccSendReceive(java.lang.String aString,
long aTimeout)
Sends a String to the communication services and waits for to receive data until the timeout limit is exceeded. |
void |
closeConnection()
Disconnects from the 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 an MQManager and opens the send and receive queues. |
void |
fireMessageReceived(QueueEvent event)
Supports listener events. |
java.lang.String |
getAliasQueueManagerNameSend()
Gets the aliasQueueManagerNameSend |
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. |
int |
getCcsid()
|
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 value. |
int |
getEncoding()
Gets the encoding property value. |
int |
getEstablishConnectionRetries()
Gets the establishConnectionRetries property value. |
int |
getExpiry()
Gets the expiry property 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 reply queue. |
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 value. |
boolean |
getMatchCorrelationId()
Gets the matchCorrelationId property 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 value. |
int |
getReceiveReturnCode()
Gets the receiveReturnCode property value. |
java.lang.String |
getReplyDynamicQName()
Gets the replyDynamicQName property value. |
java.lang.String |
getReplyToQName()
Gets the replyToQName property value. |
int |
getReplyToQOpenOptions()
Gets the ReplyToQ open options (int) value. |
java.lang.String |
getSendDynamicQName()
Gets the SendDynamicQName property value. |
int |
getSendReturnCode()
Gets the sendReturnCode property value. |
java.lang.String |
getSendToQName()
Gets the sendToQName property value. |
int |
getSendToQOpenOptions()
Gets the SendToQ open options value. |
boolean |
getServer()
Gets the server property value. |
java.lang.String |
getStatus()
|
boolean |
getSynchronousMode()
Gets the synchronousMode property value. |
int |
getTimeBetweenRetries()
Gets the timeBetweenRetries property 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 XML 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 whether the DeadLetter queue manager is open. |
boolean |
isFree()
Returns whether the session is free. |
boolean |
isOffline()
Returns whether the session is offline. |
boolean |
isResetStatus()
|
int |
parseInt(java.lang.String param)
Parses the input string into its associated MQ code. |
byte[] |
putToPutSendQueue(com.ibm.mq.MQMessage aMessage)
Puts aMessage (an MQMessage) into the putSendQueue and returns the correlation identifier for this message. |
byte[] |
putToPutSendQueue(java.lang.String aData)
Puts an MQMessage into the putSendQueue, creates the aData and message default options, and returns the correlation ID of this message. |
protected void |
receive()
Performs the receive method used by thread listeners when working in asynchronous mode. |
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 to a specified value. |
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()
Runs the listener for messages. |
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 |
setAliasQueueManagerNameSend(java.lang.String aliasQueueManagerNameSend)
Sets the aliasQueueManagerNameSend |
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 |
setCcsid(int ccsid)
|
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 |
setExpiry(int newExpiry)
Sets the expiry property 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 |
setReplyDynamicQName(java.lang.String rqname)
Sets the ReplyDynamicQName 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 |
setSendDynamicQName(java.lang.String sqname)
Sets the SendDynamicQName property (java.lang.String) 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.btt.base.Service |
---|
externalizer, getExternalizer, getTagName, readExternal, readExternal, readObject, removeExternal, setExternalizer, toStrings, toTags, writeExternal, writeExternal |
Methods inherited from class com.ibm.btt.base.BTTProcessorNotifier |
---|
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 |
Methods inherited from interface com.ibm.btt.base.ProcessorNotifier |
---|
addHandler, getHandlersList, getName, removeHandler, setName, signalEvent, signalEvent |
Methods inherited from interface com.ibm.btt.base.Externalizable |
---|
getName, setName |
Field Detail |
---|
public static final java.lang.String COMPID
protected com.ibm.mq.MQQueue SendToQueue
protected com.ibm.mq.MQQueue ReplyToQueue
protected com.ibm.mq.MQGetMessageOptions gmo
public Semaphore receiveSem
public static final java.lang.String LISTEN_THREAD
public static final java.lang.String DEADLETTERQ
protected transient QueueListener aQueueListener
protected int receiveReturnCode
protected boolean ReplyQueueAccessed
protected boolean SendQueueAccessed
protected com.ibm.mq.MQMessage tempMqMessage
protected Hashtable eventParameter
protected Hashtable eventParameterD
protected Hashtable messageTable
protected Hashtable messageQTable
protected java.lang.String EXCEPTION
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 java.lang.String ReplyDynamicQName
public java.lang.String ReplyModelQName
public java.lang.String SendDynamicQName
public java.lang.String SendModelQName
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
protected boolean isDeadLetterThreadAlive
Constructor Detail |
---|
public MQConnection()
public MQConnection(java.lang.String aName) throws java.io.IOException
aName
- java.lang.String
java.io.IOException
- .Method Detail |
---|
public void addQueueListener(QueueListener newListener)
addQueueListener
in interface MQConnectionService
newListener
- com.ibm.btt.services.mq.QueueListenerpublic void ccClose() throws DSECCException
ccClose
in interface CommonCommunicationsService
aString
- java.lang.String
DSECCException
- .public void ccOpen() throws DSECCException
ccOpen
in interface CommonCommunicationsService
DSECCException
- .public CCMessage ccReceiveData(long aTimeout) throws DSECCException
ccReceiveData
in interface CommonCommunicationsService
aTimeout
- long
DSECCException.
DSECCException
public void ccSendData(java.lang.String aString) throws DSECCException
ccSendData
in interface CommonCommunicationsService
aString
- java.lang.String
DSECCException
public CCMessage ccSendReceive(java.lang.String aString, long aTimeout) throws DSECCException
ccSendReceive
in interface CommonCommunicationsService
aString
- java.lang.StringaTimeout
- long
DSECCException
public void closeConnection() throws com.ibm.mq.MQException
closeConnection
in interface MQConnectionService
com.ibm.mq.MQException.
com.ibm.mq.MQException
public void disconnectQueueManager() throws com.ibm.mq.MQException
com.ibm.mq.MQException
public void establishConnection() throws com.ibm.mq.MQException
establishConnection
in interface MQConnectionService
com.ibm.mq.MQException
public void fireMessageReceived(QueueEvent event)
fireMessageReceived
in interface MQConnectionService
event
- com.ibm.btt.services.mq.QueueEventpublic java.lang.String getAliasQueueManagerNameSend()
public java.lang.String getApplicationName()
setApplicationName(java.lang.String)
public boolean getAutomaticConnectionEstablishment()
getAutomaticConnectionEstablishment
in interface MQConnectionService
#setAutomaticSessionEstablishment
public java.lang.String getCcClosedEventName()
getCcClosedEventName
in interface CommonCommunicationsService
public java.lang.String getCcDataReceivedEventName()
getCcDataReceivedEventName
in interface CommonCommunicationsService
public java.lang.String getCcErrorReceivedEventName()
getCcErrorReceivedEventName
in interface CommonCommunicationsService
public java.lang.String getCcOpenedEventName()
getCcOpenedEventName
in interface CommonCommunicationsService
public java.lang.String getchannelName()
public int getChannelStatus(java.lang.String channelName) throws com.ibm.mq.MQException
channelName
- - The name of the inquired channel
com.ibm.mq.MQException.
com.ibm.mq.MQException
public int getCharSet()
setCharSet(int)
public java.lang.String getDeadLetterQName()
getDeadLetterQName
in interface MQConnectionService
public int getEncoding()
setEncoding(int)
public int getEstablishConnectionRetries()
setEstablishConnectionRetries(int)
public int getExpiry()
setExpiry(int)
public java.lang.String getFormat()
setFormat(java.lang.String)
public com.ibm.mq.MQMessage getFromDeadLetterQueue() throws com.ibm.mq.MQException
com.ibm.mq.MQException
public com.ibm.mq.MQMessage getFromGetReplyQueue() throws com.ibm.mq.MQException, java.io.IOException
MQException.
com.ibm.mq.MQException
java.io.IOException
public com.ibm.mq.MQMessage getFromGetReplyQueue(byte[] aCorrelationId) throws com.ibm.mq.MQException, java.io.IOException
com.ibm.mq.MQException
java.io.IOException
public int getGetMessageOptionsOptions()
public java.lang.String getHostName()
public boolean getInUse()
setInUse(boolean)
public boolean getMatchCorrelationId()
#setmatchCorrelationId
public int getMessageType()
setMessageType(int)
public int getPersistence()
setPersistence(int)
public int getPortNumber()
public int getPutMessageOptionsOptions()
public java.lang.String getQmgrReply()
setQmgrReply(java.lang.String)
public java.lang.String getQueueManagerName()
public int getReceiveReturnCode()
public java.lang.String getReplyDynamicQName()
public java.lang.String getReplyToQName()
public int getReplyToQOpenOptions()
public java.lang.String getSendDynamicQName()
public int getSendReturnCode()
public java.lang.String getSendToQName()
public int getSendToQOpenOptions()
Gets the SendToQ open options value.
public boolean getServer()
public java.lang.String getStatus()
getStatus
in interface MQConnectionService
#setSessionStatus
public boolean getSynchronousMode()
#setConfirmMode
public int getTimeBetweenRetries()
setTimeBetweenRetries(int)
public int getTimeout()
Gets the timeout property value.
setTimeout(int)
public java.lang.String getUserId()
setUserId(java.lang.String)
protected void initializeCounter()
public java.lang.Object initializeFrom(Tag aTag) throws java.io.IOException, DSEException
initializeFrom
in class Service
aTag
- com.ibm.btt.base.Tag
java.io.IOException
DSEException
public void initInstance() throws DSECCException, DSEInvalidArgumentException
DSEInvalidArgumentException
DSEException
DSECCException
public void initManagers() throws com.ibm.mq.MQException
DSEInvalidArgumentException
DSEException
com.ibm.mq.MQException
public boolean isCloseMessage(java.lang.Object aMessage)
public boolean isDeadLetterQReset()
public boolean isFree()
isFree
in interface CommonCommunicationsService
public boolean isOffline()
isOffline
in interface CommonCommunicationsService
public boolean isResetStatus()
public int parseInt(java.lang.String param)
param
- java.lang.String
public byte[] putToPutSendQueue(com.ibm.mq.MQMessage aMessage) throws com.ibm.mq.MQException
aMessage
- The message to put into the send queue
com.ibm.mq.MQException
public byte[] putToPutSendQueue(java.lang.String aData) throws com.ibm.mq.MQException, java.io.IOException
aMessage
- - The message to put into the send queue
MQException.
java.io.IOException.
com.ibm.mq.MQException
java.io.IOException
protected void receive() throws java.io.IOException
java.io.IOException
public java.lang.Object receive(byte[] aCorrelationId) throws com.ibm.mq.MQException, java.io.IOException
receive
in interface MQConnectionService
com.ibm.mq.MQException
java.io.IOException
public java.lang.Object receive(byte[] aCorrelationId, long aTimeout) throws com.ibm.mq.MQException, java.io.IOException
receive
in interface MQConnectionService
correlationId(byte[])
- The message correlation identifier to get the correct message.timeout(long)
-
com.ibm.mq.MQException
java.io.IOException
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)
removeQueueListener
in interface MQConnectionService
newListener
- com.ibm.btt.services.mq.QueueListenerpublic int resetChannel(java.lang.String channelName) throws com.ibm.mq.MQException
channelName
- The name of the channel to be reset.
com.ibm.mq.MQException.
com.ibm.mq.MQException
public int resetChannel(java.lang.String channelName, int msgSeqNumber) throws com.ibm.mq.MQException
channelName
- The name of the channel to be resetmsgSeqNumber
- The new sequence number
com.ibm.mq.MQException.
com.ibm.mq.MQException
public DSECCException returnException(java.lang.Exception e)
public java.lang.String returnStringFromMessage(java.lang.Object aMessage) throws DSECCException
DSECCException
public void run()
run
in interface java.lang.Runnable
public byte[] send(Context aContext, FormatElement aFormat) throws DSEException, com.ibm.mq.MQException, java.io.IOException
aContext
- com.ibm.btt.base.Context - The context element objectaFormat
- com.ibm.btt.base.FormatElement - The format element object
DSEException
com.ibm.mq.MQException
java.io.IOException
public byte[] send(Context aContext, java.lang.String aFormatName) throws DSEException, com.ibm.mq.MQException
aContext
- com.ibm.btt.base.Context - The format elementaFormatName
- java.lang.String - The format element name
com.ibm.mq.MQException
DSEException
public byte[] send(java.lang.Object inputMessage) throws com.ibm.mq.MQException
send
in interface MQConnectionService
aString
- java.lang.String
com.ibm.mq.MQException
public byte[] send(java.lang.String inputMessage) throws com.ibm.mq.MQException, java.io.IOException
send
in interface MQConnectionService
aString
- java.lang.String
com.ibm.mq.MQException
java.io.IOException
public void setAliasQueueManagerNameSend(java.lang.String aliasQueueManagerNameSend)
aliasQueueManagerNameSend
- The aliasQueueManagerNameSend to setpublic void setApplicationName(java.lang.String newApplicationName)
newApplicationName
- java.lang.StringgetApplicationName()
public void setAutomaticConnectionEstablishment(boolean automaticEstablishment)
automaticEstablishment
- The new value for the propertygetAutomaticConnectionEstablishment()
public void setChannelName(java.lang.String chname)
The
- Channel(java.lang.String) property valuepublic void setCharSet(int newCharSet)
newCharSet
- intgetCharSet()
public void setDeadLetterMessageOptionsMatchOptions(int options)
options(int)
- The DeadLetter message matchOptionspublic void setDeadLetterMessageOptionsWaitInterval(int options)
options(int)
- The waitInterval DeadLetter message optionpublic void setDeadLetterQName(java.lang.String dlname)
The
- deadLetterQName(java.lang.String) property valuepublic void setEncoding(int newEncoding)
newEncoding
- intgetEncoding()
public void setEstablishConnectionRetries(int establishConnectionRetries)
establishSessionRetries
- The new value for the property#getEstablishSessionRetries
public void setExpiry(int newExpiry)
Sets the expiry property value.
newExpiry
- intgetExpiry()
public void setFormat(java.lang.String newFormat)
newFormat
- java.lang.Stringpublic void setGetMessageOptionsMatchOptions(int options)
options(int)
- The GetMessageOptions matchoptionspublic void setGetMessageOptionsOptions(int options)
options(int)
- The GetMessageOptions optionspublic void setGetMessageOptionsWaitInterval(int options)
options(int)
- The WaitInterval GetMessageOptions optionpublic void setHostName(java.lang.String hname)
The
- hostName(java.lang.String) property valuepublic void setInUse(boolean anInUse)
setInUse
in interface CommonCommunicationsService
anInUse
- The new value for the propertygetInUse()
public void setMatchCorrelation(boolean newValue)
newValue
- The new value for the property#getmatchCorrelation
public void setMessageType(int newMessageType)
newMessageType
- intpublic void setPersistence(int newPersistence)
newPersistence
- intgetPersistence()
public void setPortNumber(int pnum)
The
- port(int) property valuepublic void setPutMessageOptionsOptions(int options)
options
- The PutMessageOptions optionspublic void setQmgrName(java.lang.String qmgrname)
The
- QMgrName property valuepublic void setQmgrReply(java.lang.String newQmgrReply)
newQmgrReply
- java.lang.Stringpublic void setReplyDynamicQName(java.lang.String rqname)
The
- replyDynamicQName property valuepublic void setReplyQName(java.lang.String rqname)
The
- replyToQName property valuepublic void setReplyToQOpenOptions(int options)
options
- The ReplyToQ open optionspublic void setSendDynamicQName(java.lang.String sqname)
The
- SendDynamicQName property valuepublic void setSendQName(java.lang.String sqname)
The
- sendToQName property valuepublic void setSendToQOpenOptions(int options)
Sets SendToQOpenOptions field property (int) value.
options
- The SendToQ open optionspublic void setServer(boolean aBoolean)
aBoolean
- The new boolean value for the propertygetAutomaticConnectionEstablishment()
public void setSynchronousMode(boolean aSynchronousMode)
aSynchronousMode
- The new value for the propertygetSynchronousMode()
public void setTimeBetweenRetries(int timeBetweenRetries)
timeBetweenRetries
- The new value for the propertygetTimeBetweenRetries()
public void setTimeout(int newTimeout)
newTimeout
- intgetTimeout()
public void setUserId(java.lang.String newUserId)
newUserId
- java.lang.Stringpublic int getCcsid()
public void setCcsid(int ccsid)
public int startChannel(java.lang.String channelName) throws com.ibm.mq.MQException
channelName
- The name of the channel to be started
com.ibm.mq.MQException
public int stopChannel(java.lang.String channelName) throws com.ibm.mq.MQException
Stops the specified channel. The possible return values are:
channelName
- The name of the channel to be stopped
com.ibm.mq.MQException.
com.ibm.mq.MQException
public void terminate()
terminate
in interface ProcessorNotifier
terminate
in interface MQConnectionService
terminate
in class Service
public java.lang.String toString()
toString
in class Service
|
IBM WebSphere Multichannel Bank Transformation Toolkit Javadoc | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |