public class MAmxProducerImpl
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected int |
m_activityID |
protected MComponentRegistry |
m_componentRegistry |
protected java.lang.String |
m_correlationId |
protected MAmxEndpointSpec |
m_endpointSpec |
protected java.lang.Object |
m_lock |
protected int |
m_priority |
protected java.lang.String |
m_replyDestinationName |
protected MSession |
m_session |
protected java.util.Vector |
m_TPlugin |
protected static MAmxMarshaller |
s_marshaller |
Modifier | Constructor and Description |
---|---|
protected |
MAmxProducerImpl(MComponentRegistry registry,
java.lang.String name,
MSession p_session,
MAmxEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
void |
addTPluginName(java.lang.String sTPluginName) |
void |
finalize() |
long |
getNumMessagesPublished() |
java.lang.String |
getOperationName(MTree tree) |
protected long |
incrementMessagesSentCount() |
protected AmxMessage |
packMessage(MTree data) |
protected static void |
recordPerformanceInfo(MComponentRegistry componentRegistry,
int p_activityID,
AmxMessage msg) |
void |
send(MTree data) |
protected void |
send(java.lang.String operationName,
AmxMessage msg,
long timeout) |
void |
sendWithReply(MTree data,
MSubscriber subscriber) |
MTree |
sendWithSyncReply(MTree data,
long timeout) |
void |
setCorrelationId(java.lang.String sCorrelationId) |
void |
setPriority(int priority) |
void |
setReplyDestinationName(java.lang.String replyDestinationName) |
protected MTree |
unpack(AmxMessage msg) |
void |
unRegisterListener(java.lang.String listenerName) |
protected java.lang.Object m_lock
protected MSession m_session
protected java.lang.String m_replyDestinationName
protected MAmxEndpointSpec m_endpointSpec
protected static MAmxMarshaller s_marshaller
protected MComponentRegistry m_componentRegistry
protected int m_activityID
protected java.util.Vector m_TPlugin
protected java.lang.String m_correlationId
protected int m_priority
protected MAmxProducerImpl(MComponentRegistry registry, java.lang.String name, MSession p_session, MAmxEndpointSpec endpointSpec)
public void send(MTree data) throws MException
MException
public void sendWithReply(MTree data, MSubscriber subscriber) throws MException
MException
public MTree sendWithSyncReply(MTree data, long timeout) throws MException
MException
public void setReplyDestinationName(java.lang.String replyDestinationName)
protected final AmxMessage packMessage(MTree data) throws MException
MException
protected void send(java.lang.String operationName, AmxMessage msg, long timeout) throws MException
MException
public long getNumMessagesPublished()
protected long incrementMessagesSentCount()
public void addTPluginName(java.lang.String sTPluginName)
protected MTree unpack(AmxMessage msg) throws MException
MException
public void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable
public void setCorrelationId(java.lang.String sCorrelationId)
public void setPriority(int priority)
public void unRegisterListener(java.lang.String listenerName) throws MException
MException
protected static void recordPerformanceInfo(MComponentRegistry componentRegistry, int p_activityID, AmxMessage msg)
public java.lang.String getOperationName(MTree tree)