FileDocCategorySizeDatePackage
JMSEndpoint.javaAPI DocApache Axis 1.44541Sat Apr 22 18:57:28 BST 2006org.apache.axis.transport.jms

JMSEndpoint

public abstract class JMSEndpoint extends Object
JMSEndpoint encapsulates interactions w/ a JMS destination.
author
Jaime Meritt (jmeritt@sonicsoftware.com)
author
Richard Chung (rchung@sonicsoftware.com)
author
Dave Chappell (chappell@sonicsoftware.com)

Fields Summary
private JMSConnector
m_connector
Constructors Summary
protected JMSEndpoint(JMSConnector connector)

        m_connector = connector;
    
Methods Summary
public byte[]call(byte[] message, long timeout)
Send a message and wait for a response.

param
message
param
timeout
return
throws
JMSException

        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.

param
message
param
timeout
param
properties
return
throws
JMSException

        if(properties != null)
            properties = (HashMap)properties.clone();
        return m_connector.getSendConnection().call(this, message, timeout, properties);
    
protected SubscriptioncreateSubscription(javax.jms.MessageListener listener, java.util.HashMap properties)

        return new Subscription(listener, this, properties);
    
public booleanequals(java.lang.Object object)

        if(object == null || !(object instanceof JMSEndpoint))
            return false;
        return true;
    
abstract javax.jms.DestinationgetDestination(javax.jms.Session session)

public inthashCode()

        return toString().hashCode();
    
public voidregisterListener(javax.jms.MessageListener listener)
Register a MessageListener.

param
listener
throws
JMSException

        m_connector.getReceiveConnection().subscribe(createSubscription(listener, null));
    
public voidregisterListener(javax.jms.MessageListener listener, java.util.HashMap properties)
Register a MessageListener.

param
listener
param
properties
throws
JMSException

        if(properties != null)
            properties = (HashMap)properties.clone();
        m_connector.getReceiveConnection().subscribe(createSubscription(listener, properties));
    
public voidsend(byte[] message)
Send a message w/o waiting for a response.

param
message
throws
JMSException

        m_connector.getSendConnection().send(this, message, null);
    
public voidsend(byte[] message, java.util.HashMap properties)
Send a message w/o waiting for a response.

param
message
param
properties
throws
JMSException

        if(properties != null)
            properties = (HashMap)properties.clone();
        m_connector.getSendConnection().send(this, message, properties);
    
public voidunregisterListener(javax.jms.MessageListener listener, java.util.HashMap properties)
Unregister a message listener.

param
listener
param
properties

        if(properties != null)
            properties = (HashMap)properties.clone();
        m_connector.getReceiveConnection().unsubscribe(createSubscription(listener, properties));
    
public voidunregisterListener(javax.jms.MessageListener listener)
Unregister a message listener.

param
listener

        m_connector.getReceiveConnection().unsubscribe(createSubscription(listener, null));