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 |
---|
MAmxProducer(MComponentRegistry registry,
java.lang.String name,
MSession p_session,
MAmxEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
void |
addTPluginName(java.lang.String sTPluginName) |
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 |
setReplyDestinationName(java.lang.String replyDestinationName) |
void |
unRegisterListener(java.lang.String listenerName) |
disableJmsMessageId, isAeMsgOn, setAeMsgOn, setJmsCorrelationId, setJmsPriority
public MAmxProducer(MComponentRegistry registry, java.lang.String name, MSession p_session, MAmxEndpointSpec endpointSpec) 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 unRegisterListener(java.lang.String listenerName) throws MException
unRegisterListener
in class MProducer
MException
public void addTPluginName(java.lang.String sTPluginName)
addTPluginName
in class MProducer