Methods Summary |
---|
public byte[] | call(byte[] message, long timeout)Send a message and wait for a response.
return m_connector.getSendConnection().call(this, message, timeout, null);
|
public byte[] | call(byte[] message, long timeout, java.util.HashMap properties)Send a message and wait for a response.
if(properties != null)
properties = (HashMap)properties.clone();
return m_connector.getSendConnection().call(this, message, timeout, properties);
|
protected Subscription | createSubscription(javax.jms.MessageListener listener, java.util.HashMap properties)
return new Subscription(listener, this, properties);
|
public boolean | equals(java.lang.Object object)
if(object == null || !(object instanceof JMSEndpoint))
return false;
return true;
|
abstract javax.jms.Destination | getDestination(javax.jms.Session session)
|
public int | hashCode()
return toString().hashCode();
|
public void | registerListener(javax.jms.MessageListener listener)Register a MessageListener.
m_connector.getReceiveConnection().subscribe(createSubscription(listener, null));
|
public void | registerListener(javax.jms.MessageListener listener, java.util.HashMap properties)Register a MessageListener.
if(properties != null)
properties = (HashMap)properties.clone();
m_connector.getReceiveConnection().subscribe(createSubscription(listener, properties));
|
public void | send(byte[] message)Send a message w/o waiting for a response.
m_connector.getSendConnection().send(this, message, null);
|
public void | send(byte[] message, java.util.HashMap properties)Send a message w/o waiting for a response.
if(properties != null)
properties = (HashMap)properties.clone();
m_connector.getSendConnection().send(this, message, properties);
|
public void | unregisterListener(javax.jms.MessageListener listener, java.util.HashMap properties)Unregister a message listener.
if(properties != null)
properties = (HashMap)properties.clone();
m_connector.getReceiveConnection().unsubscribe(createSubscription(listener, properties));
|
public void | unregisterListener(javax.jms.MessageListener listener)Unregister a message listener.
m_connector.getReceiveConnection().unsubscribe(createSubscription(listener, null));
|