|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
The MQConnectionService interface provides MQConnection services.
Field Summary | |
static java.lang.String |
CODEPAGE
|
static java.lang.String |
DSEUSER
|
static int |
MQ_CHANNEL_NAME_LENGTH
|
static int |
MQCACH_CHANNEL_NAME
|
static int |
MQCC_OK
|
static int |
MQCCSI_DEFAULT
|
static int |
MQCFC_LAST
|
static int |
MQCFH_STRUC_LENGTH
|
static int |
MQCFH_VERSION_1
|
static int |
MQCFIN_STRUC_LENGTH
|
static int |
MQCFST_STRUC_LENGTH_FIXED
|
static int |
MQCFT_COMMAND
|
static int |
MQCFT_INTEGER
|
static int |
MQCFT_STRING
|
static int |
MQCHS_BINDING
|
static int |
MQCHS_INACTIVE
|
static int |
MQCHS_INITIALIZING
|
static int |
MQCHS_PAUSED
|
static int |
MQCHS_REQUESTING
|
static int |
MQCHS_RETRYING
|
static int |
MQCHS_RUNNING
|
static int |
MQCHS_STARTING
|
static int |
MQCHS_STOPPED
|
static int |
MQCHS_STOPPING
|
static int |
MQCMD_INQUIRE_CHANNEL_STATUS
|
static int |
MQCMD_RESET_CHANNEL
|
static int |
MQCMD_START_CHANNEL
|
static int |
MQCMD_STOP_CHANNEL
|
static int |
MQIACH_CHANNEL_STATUS
|
static int |
MQIACH_MSG_SEQUENCE_NUMBER
|
static int |
MQRC_NONE
|
static int |
MQRCCF_CHANNEL_IN_USE
|
static java.lang.String |
NORC
|
Fields inherited from interface com.ibm.dse.services.comms.CommonCommunicationsService |
CLOSED,
DATA,
DATASENT,
ERROR,
OPENED,
RECEIVERC,
TIMEOUT |
Method Summary | |
void |
addQueueListener(QueueListener newListener)
Adds a listener to Queue |
void |
closeConnection()
Disconnects from queue manager, and removes the used queues. |
void |
establishConnection()
Establishes a connection with a MQManager. |
void |
fireMessageReceived(QueueEvent event)
Supports listener events. |
boolean |
getAutomaticConnectionEstablishment()
Gets the AutomaticConnectionEstablishment property (boolean) value. |
java.lang.String |
getDeadLetterQName()
Gets the deadLetterQName property (String) value. |
java.lang.String |
getStatus()
Gets the communication status value. |
java.lang.Object |
receive(byte[] aCorrelationId)
Performs the receive method. |
java.lang.Object |
receive(byte[] aCorrelationId,
long aTimeout)
Performs the receive method. |
void |
removeQueueListener(QueueListener newListener)
Removes queue listener. |
byte[] |
send(java.lang.Object inputMessage)
Performs the send method. |
byte[] |
send(java.lang.String inputMessage)
Performs the send method. |
void |
terminate()
Terminates the conversation. |
Methods inherited from interface com.ibm.dse.services.comms.CommonCommunicationsService |
ccClose,
ccOpen,
ccReceiveData,
ccSendData,
ccSendReceive,
getCcClosedEventName,
getCcDataReceivedEventName,
getCcErrorReceivedEventName,
getCcOpenedEventName,
isFree,
isOffline,
setInUse |
Methods inherited from interface com.ibm.dse.base.Notifier |
addHandler,
getHandlersList,
getName,
removeHandler,
setName,
signalEvent,
signalEvent |
Field Detail |
public static final int MQCHS_INACTIVE
public static final int MQCHS_BINDING
public static final int MQCHS_STARTING
public static final int MQCHS_RUNNING
public static final int MQCHS_STOPPING
public static final int MQCHS_RETRYING
public static final int MQCHS_STOPPED
public static final int MQCHS_REQUESTING
public static final int MQCHS_PAUSED
public static final int MQCHS_INITIALIZING
public static final java.lang.String NORC
public static final java.lang.String CODEPAGE
public static final int MQCFST_STRUC_LENGTH_FIXED
public static final int MQCFIN_STRUC_LENGTH
public static final int MQ_CHANNEL_NAME_LENGTH
public static final int MQCFT_COMMAND
public static final int MQCFH_STRUC_LENGTH
public static final int MQCFH_VERSION_1
public static final int MQCMD_RESET_CHANNEL
public static final int MQCMD_START_CHANNEL
public static final int MQCMD_STOP_CHANNEL
public static final int MQCMD_INQUIRE_CHANNEL_STATUS
public static final int MQCFC_LAST
public static final int MQCC_OK
public static final int MQRC_NONE
public static final int MQCFT_STRING
public static final int MQCFT_INTEGER
public static final int MQCACH_CHANNEL_NAME
public static final int MQCCSI_DEFAULT
public static final int MQIACH_CHANNEL_STATUS
public static final int MQIACH_MSG_SEQUENCE_NUMBER
public static final int MQRCCF_CHANNEL_IN_USE
public static final java.lang.String DSEUSER
Method Detail |
public void addQueueListener(QueueListener newListener)
newListener
- com.ibm.dse.services.mq.QueueListenerpublic void closeConnection() throws java.lang.Exception
Disconnects from queue manager, and removes the used queues.
public void establishConnection() throws java.lang.Exception
Establishes a connection with a MQManager.
public void fireMessageReceived(QueueEvent event)
event
- com.ibm.dse.services.mq.QueueEventpublic boolean getAutomaticConnectionEstablishment()
public java.lang.String getDeadLetterQName()
public java.lang.String getStatus()
Gets the communication status value. Possible values are:
#setSessionStatus
public java.lang.Object receive(byte[] aCorrelationId) throws java.lang.Exception
correlationId.
- The message correlation identifier to get the correct message.public java.lang.Object receive(byte[] aCorrelationId, long aTimeout) throws java.lang.Exception
correlationId.
- The message correlation identifier to get the correct message.timeout.
- public void removeQueueListener(QueueListener newListener)
newListener
- com.ibm.dse.services.mq.QueueListenerpublic byte[] send(java.lang.Object inputMessage) throws java.lang.Exception
aString(java.lang.Object).
- The message to send.public byte[] send(java.lang.String inputMessage) throws java.lang.Exception
aString
- java.lang.String.The message to be sent.public void terminate()
Terminates the conversation. This method terminates the internal thread and closes conversation ABNORMALY, if required (if in a RECEIVE state).
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |