ejava.examples.jmsmechanics

Class JMSAdminHornetQ

java.lang.Object

ejava.examples.jmsmechanics.JMSAdminHornetQ

All Implemented Interfaces:

JMSAdmin

public class JMSAdminHornetQ
extends Object
implements JMSAdmin

This class implements a client to dynamically create JMS resources on the server.

Field Summary

Fields

Modifier and Type	Field and Description
private Connection	connection
private String	jndiPrefix
private static org.apache.commons.logging.Log	log
private Queue	managementQueue

Constructor Summary

Constructors

Constructor and Description
JMSAdminHornetQ(ConnectionFactory connFactory, String adminUser, String adminPassword)

Method Summary

Modifier and Type	Method and Description
void	close()
private static String	concat(String name1, String name2) Concatenates two JNDI names making sure there is a single "/" character separating them
JMSAdmin	deployDestination(String method, String name, String jndiName)
JMSAdmin	deployQueue(String name, String jndiName)
JMSAdmin	deployTopic(String name, String jndiName)
JMSAdmin	destroyDestination(String method, String name)
JMSAdmin	destroyQueue(String name)
JMSAdmin	destroyTopic(String name)
JMSAdmin	setJNDIPrefix(String prefix) Sets a prefix to add to any JNDI name registered.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

private static final org.apache.commons.logging.Log log

connection

private Connection connection

managementQueue

private Queue managementQueue

jndiPrefix

private String jndiPrefix

Constructor Detail

JMSAdminHornetQ

public JMSAdminHornetQ(ConnectionFactory connFactory,
                       String adminUser,
                       String adminPassword)
                throws JMSException

Throws:

JMSException

Method Detail

setJNDIPrefix

public JMSAdmin setJNDIPrefix(String prefix)

Description copied from interface: JMSAdmin

Sets a prefix to add to any JNDI name registered. This is required when the server is running within the application server and only specially prefixed JNDI names are made available for global use.

Specified by:

setJNDIPrefix in interface JMSAdmin

Returns:

close

public void close()
           throws JMSException

Specified by:

close in interface JMSAdmin

Throws:

JMSException

concat

private static String concat(String name1,
                             String name2)

Concatenates two JNDI names making sure there is a single "/" character separating them

Parameters:

name1 -

name2 -

Returns:

deployDestination

public JMSAdmin deployDestination(String method,
                                  String name,
                                  String jndiName)
                           throws Exception

Throws:

Exception

destroyDestination

public JMSAdmin destroyDestination(String method,
                                   String name)
                            throws Exception

Throws:

Exception

deployTopic

public JMSAdmin deployTopic(String name,
                            String jndiName)
                     throws Exception

Specified by:

deployTopic in interface JMSAdmin

Throws:

Exception

deployQueue

public JMSAdmin deployQueue(String name,
                            String jndiName)
                     throws Exception

Specified by:

deployQueue in interface JMSAdmin

Throws:

Exception

destroyTopic

public JMSAdmin destroyTopic(String name)
                      throws Exception

Specified by:

destroyTopic in interface JMSAdmin

Throws:

Exception

destroyQueue

public JMSAdmin destroyQueue(String name)
                      throws Exception

Specified by:

destroyQueue in interface JMSAdmin

Throws:

Exception