AMX, JMS, M_FILE_SINK_ID, M_HAWK_SINK_ID, M_JMS_SINK_ID, M_RV_SINK_ID, M_SINK_ID, M_STDERR_SINK_ID, M_STDOUT_SINK_ID, M_STREAM_SINK_ID, RV
Constructor and Description |
---|
MJmsProducer(MComponentRegistry registry,
java.lang.String name,
MSession p_session,
MJmsEndpointSpec endpointSpec,
java.lang.Object destination) |
Modifier and Type | Method and Description |
---|---|
void |
addTPluginName(java.lang.String sTPluginName) |
void |
disableJmsMessageId(boolean bShouldDisable) |
int |
getDeliveryMode() |
java.lang.String |
getDestinationName() |
MEndpointSpec |
getEndpointSpec() |
long |
getNumMessagesPublished() |
java.lang.String |
getReplyDestinationName() |
int |
getTransportID() |
void |
send(MTree p_message) |
void |
sendWithReply(MTree data,
MSubscriber subscriber) |
MTree |
sendWithSyncReply(MTree data,
long timeout) |
void |
setDestinationName(java.lang.String destinationName) |
void |
setJmsCorrelationId(java.lang.String sCorrelationId) |
void |
setJmsPriority(int priority) |
void |
setReplyDestinationName(java.lang.String replyDestinationName) |
void |
unRegisterListener(java.lang.String listenerName) |
isAeMsgOn, setAeMsgOn
public MJmsProducer(MComponentRegistry registry, java.lang.String name, MSession p_session, MJmsEndpointSpec endpointSpec, java.lang.Object destination) throws MException
MException
public void send(MTree p_message) throws MException
send
in class MProducer
MException
public void sendWithReply(MTree data, MSubscriber subscriber) throws MException
sendWithReply
in class MProducer
MException
public MTree sendWithSyncReply(MTree data, long timeout) throws MException
sendWithSyncReply
in class MProducer
MException
public MEndpointSpec getEndpointSpec()
getEndpointSpec
in class MProducer
public java.lang.String getDestinationName()
getDestinationName
in class MProducer
public void setDestinationName(java.lang.String destinationName) throws MException
setDestinationName
in class MProducer
MException
public void setReplyDestinationName(java.lang.String replyDestinationName)
setReplyDestinationName
in class MProducer
public java.lang.String getReplyDestinationName()
getReplyDestinationName
in class MProducer
public int getDeliveryMode()
getDeliveryMode
in class MProducer
public long getNumMessagesPublished()
getNumMessagesPublished
in class MProducer
public int getTransportID()
public void setJmsCorrelationId(java.lang.String sCorrelationId)
setJmsCorrelationId
in class MProducer
public void disableJmsMessageId(boolean bShouldDisable)
disableJmsMessageId
in class MProducer
public void setJmsPriority(int priority)
setJmsPriority
in class MProducer
public void unRegisterListener(java.lang.String listenerName) throws MException
unRegisterListener
in class MProducer
MException
public void addTPluginName(java.lang.String sTPluginName)
addTPluginName
in class MProducer