Mom4jConsole

Overview

Package

Class

Use

Deprecated

Index

Home >> All >> org >> mom4j >> [ api overview ]

PREV CLASS NEXT CLASS

SUMMARY:

JAVADOC |

Sourc code of org.mom4j.api.Mom4jConsole

SOURCE |

DOWNLOAD | NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.mom4j.api
Interface Mom4jConsole

public interface Mom4jConsole

This interface allows for controlling the mom4j server as well as sending and receiving messages.

Version:: $Id: Mom4jConsole.java,v 1.2 2003/07/25 07:33:16 the_real_grace Exp $ $Date: 2003/07/25 07:33:16 $

Method Summary

void commit(java.lang.String sessionId)
          Commits on a certain session.

void createQueue(java.lang.String name)
          Creates a queue for sending and receiving messages.

void createTopic(java.lang.String name)
          Creates a topic for sending and receiving messages.

boolean hasQueue(java.lang.String name)
          Checks the existance of a queue with a certain name.

boolean hasTopic(java.lang.String name)
          Checks the existance of a topic with a certain name.

javax.jms.Message receive(java.lang.String sessionId, java.lang.String destination, java.lang.String consumerId)
          Receives a message from a certain destination.

void register(java.lang.String destination, java.lang.String consumerId, java.lang.String messageSelector)
          Registers a message consumer.

java.lang.String registerDur(java.lang.String destination, java.lang.String subscriberName, java.lang.String consumerId, java.lang.String messageSelector)
          Registers a durable message consumer.

void rollback(java.lang.String sessionId)
          Rollback on a certain session.

void send(java.lang.String sessionId, java.lang.String destination, javax.jms.Message msg)
          Publishes a message to a certain destination.

void stop()
          Closes all open server sockets and releases all resources.

void unregister(java.lang.String destination, java.lang.String consumerId)
          Unregisters a message consumer.

void unregisterDur(java.lang.String subscriberName)
          Unregisters a (durable) message consumer.

Method Detail

createQueue

public void createQueue(java.lang.String name)
                 throws javax.jms.JMSException

Creates a queue for sending and receiving messages. The handle to the queue can be obtained via JNDI.

hasQueue

public boolean hasQueue(java.lang.String name)

Checks the existance of a queue with a certain name.

createTopic

public void createTopic(java.lang.String name)
                 throws javax.jms.JMSException

Creates a topic for sending and receiving messages. The handle to the topic can be obtained via JNDI.

hasTopic

public boolean hasTopic(java.lang.String name)

Checks the existance of a topic with a certain name.

register

public void register(java.lang.String destination,
                     java.lang.String consumerId,
                     java.lang.String messageSelector)
              throws javax.jms.JMSException

Registers a message consumer. A message consumer can only receive messages after successful registration.

registerDur

public java.lang.String registerDur(java.lang.String destination,
                                    java.lang.String subscriberName,
                                    java.lang.String consumerId,
                                    java.lang.String messageSelector)
                             throws javax.jms.JMSException

Registers a durable message consumer. A durable message consumer can only receive messages after successful registration. A durable subscription (registration of a durable message consumer) is persistent, so the subscription

unregister

public void unregister(java.lang.String destination,
                       java.lang.String consumerId)
                throws javax.jms.JMSException

Unregisters a message consumer. After deregistration, the consumer can no longer receive messages.

unregisterDur

public void unregisterDur(java.lang.String subscriberName)
                   throws javax.jms.JMSException

Unregisters a (durable) message consumer. After deregistration, the consumer can no longer receive messages.

send

public void send(java.lang.String sessionId,
                 java.lang.String destination,
                 javax.jms.Message msg)
          throws java.io.IOException,
                 javax.jms.JMSException

Publishes a message to a certain destination.

receive

public javax.jms.Message receive(java.lang.String sessionId,
                                 java.lang.String destination,
                                 java.lang.String consumerId)
                          throws java.io.IOException,
                                 javax.jms.JMSException

Receives a message from a certain destination.

commit

public void commit(java.lang.String sessionId)

Commits on a certain session. All messages that have been sent via this session are made public to the registered receivers, all messages received via this session are removed from the destinations.

rollback

public void rollback(java.lang.String sessionId)

Rollback on a certain session. All messages that have been sent via this session are discarded, all messages received via this session are made available again to all registered receivers.

stop

public void stop()

Closes all open server sockets and releases all resources.