org.jboss.jms.server.endpoint
Interface SessionEndpoint

All Superinterfaces:
Closeable
All Known Subinterfaces:
SessionDelegate
All Known Implementing Classes:
ClientSessionDelegate, ServerSessionEndpoint, SessionAdvised

public interface SessionEndpoint
extends Closeable

Version:
$Revision: 1323 $ $Id: SessionEndpoint.java 1323 2006-09-20 00:48:57Z ovidiu.feodorov@jboss.com $
Author:
Tim Fox, Ovidiu Feodorov

Method Summary
 void acknowledge(AckInfo ackInfo)
          Acknowledge a message - used for auto acknowledge
 void acknowledgeBatch(java.util.List ackInfos)
          Acknowledge a batch of messages - used with client acknowledge or dups_ok acknowledge
 void addTemporaryDestination(JBossDestination destination)
          Add a temporary destination.
 void cancelDeliveries(java.util.List ackInfos)
          Cancel some deliveries.
 BrowserDelegate createBrowserDelegate(JBossDestination queue, java.lang.String messageSelector)
           
 ConsumerDelegate createConsumerDelegate(JBossDestination destination, java.lang.String selector, boolean noLocal, java.lang.String subscriptionName, boolean connectionConsumer)
           
 JBossQueue createQueue(java.lang.String queueName)
          Creates a queue identity given a Queue name.
 JBossTopic createTopic(java.lang.String topicName)
          Creates a topic identity given a Queue name.
 void deleteTemporaryDestination(JBossDestination destination)
          Delete a temporary destination
 void send(JBossMessage message)
          Send a message
 void unsubscribe(java.lang.String subscriptionName)
          Unsubscribe the client from the durable subscription specified by subscriptionName
 
Methods inherited from interface org.jboss.jms.client.Closeable
close, closing, isClosed
 

Method Detail

createConsumerDelegate

public ConsumerDelegate createConsumerDelegate(JBossDestination destination,
                                               java.lang.String selector,
                                               boolean noLocal,
                                               java.lang.String subscriptionName,
                                               boolean connectionConsumer)
                                        throws JMSException
Throws:
JMSException

createBrowserDelegate

public BrowserDelegate createBrowserDelegate(JBossDestination queue,
                                             java.lang.String messageSelector)
                                      throws JMSException
Throws:
JMSException

createQueue

public JBossQueue createQueue(java.lang.String queueName)
                       throws JMSException
Creates a queue identity given a Queue name. Does NOT create the physical queue. The physical creation of queues is an administrative task and is not to be initiated by the JMS API, with the exception of temporary queues.

Throws:
JMSException

createTopic

public JBossTopic createTopic(java.lang.String topicName)
                       throws JMSException
Creates a topic identity given a Queue name. Does NOT create the physical topic. The physical creation of topics is an administrative task and is not to be initiated by the JMS API, with the exception of temporary topics.

Throws:
JMSException

acknowledgeBatch

public void acknowledgeBatch(java.util.List ackInfos)
                      throws JMSException
Acknowledge a batch of messages - used with client acknowledge or dups_ok acknowledge

Parameters:
ackInfos -
Throws:
JMSException

acknowledge

public void acknowledge(AckInfo ackInfo)
                 throws JMSException
Acknowledge a message - used for auto acknowledge

Parameters:
ackInfo -
Throws:
JMSException

addTemporaryDestination

public void addTemporaryDestination(JBossDestination destination)
                             throws JMSException
Add a temporary destination.

Throws:
JMSException

deleteTemporaryDestination

public void deleteTemporaryDestination(JBossDestination destination)
                                throws JMSException
Delete a temporary destination

Throws:
JMSException

unsubscribe

public void unsubscribe(java.lang.String subscriptionName)
                 throws JMSException
Unsubscribe the client from the durable subscription specified by subscriptionName

Parameters:
subscriptionName - the Name of the durable subscription to unsubscribe from
Throws:
JMSException - if the unsubscribe fails

send

public void send(JBossMessage message)
          throws JMSException
Send a message

Parameters:
message - The message to send
Throws:
JMSException

cancelDeliveries

public void cancelDeliveries(java.util.List ackInfos)
                      throws JMSException
Cancel some deliveries. This used at consumer close to cancel any undelivered messages left in the client buffer or at session recovery to cancel any messages that couldn't be redelivered locally

Parameters:
ackInfos -
Throws:
JMSException


Copyright © 2006 JBoss Inc. All Rights Reserved.