Package com.webmethods.jms.admin

Class WmJMSAdminImpl

java.lang.Object

com.webmethods.jms.admin.WmJMSAdminImpl

All Implemented Interfaces:

WmJMSAdmin

public class WmJMSAdminImpl
extends java.lang.Object
implements WmJMSAdmin

Field Summary

Fields

Modifier and Type	Field	Description
protected static java.lang.String	EVENT_TYPE_PLACEHOLDER
static java.lang.String	MESSAGE_TYPE_PROPERTY

Fields inherited from interface com.webmethods.jms.admin.WmJMSAdmin

LIFECYCLE_DESTROY_ON_DISCONNECT, LIFECYCLE_EXPLICIT_DESTROY, RECOVER_GLOBAL, RECOVER_RESTRICTED, STORAGE_GUARANTEED, STORAGE_VOLATILE, TRANSACTION_COMMIT, TRANSACTION_ROLLBACK, VALIDATION_FULL, VALIDATION_NONE, VALIDATION_OPEN

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WmJMSAdminImpl(java.lang.String brokerHost, java.lang.String brokerName, java.lang.String clientID, java.lang.String clientGroup)
protected	WmJMSAdminImpl(java.lang.String brokerHost, java.lang.String brokerName, java.lang.String clientID, java.lang.String clientGroup, SSLInfo sslinfo)
protected	WmJMSAdminImpl(java.lang.String brokerHost, java.lang.String brokerName, java.lang.String clientID, java.lang.String clientGroup, java.lang.String userName, java.lang.String password, java.lang.String truststore, boolean encryption)

Method Summary

Modifier and Type	Method	Description
void	addReceivePermission(java.lang.String clientGroup, java.lang.String eventType)	Add an event type to a client group's receive permissions.
void	addReceivePermission(javax.jms.ConnectionFactory factory, javax.jms.Destination destination)	Add a JMS destination to a connection factory's receive permissions.
void	addSendPermission(java.lang.String clientGroup, java.lang.String eventType)	Add an event type to a client group's send permissions.
void	addSendPermission(javax.jms.ConnectionFactory factory, javax.jms.Destination destination)	Add a JMS destination to a connection factory's send permissions.
void	clearClientQueue(java.lang.String client)	Clear a client's queue on the Broker.
void	clearDurableSubscriber(java.lang.String clientID, java.lang.String name)	Clear all messages for a JMS durable subscriber on the Broker.
void	clearQueue(java.lang.String name)	Clear all messages for a JMS queue on the Broker.
void	clearQueue(javax.jms.Queue queue)	Clear all messages for a JMS queue on the Broker.
boolean	clientExists(java.lang.String client)	Determine if a client exists on the Broker.
boolean	clientGroupExists(java.lang.String clientGroup)	Determine if the specified client group exists on the Broker.
void	close()	Closes the administration connection to the Broker.
void	closeClient(java.lang.String client)	Close a client on the Broker.
boolean	connectionFactoryExists(javax.jms.ConnectionFactory factory)	Determines if the JMS connection factory exists on the Broker.
void	createBroker(java.lang.String broker, java.lang.String description, boolean makeDefault)	Create a Broker on the current Broker Server.
void	createClientGroup(java.lang.String clientGroup, int storage)	Create a client group on the Broker.
void	createConnectionFactory(javax.jms.ConnectionFactory factory)	Create the JMS connection factory on the Broker.
void	createDestination(javax.jms.Destination destination)	Create a JMS destination on the Broker.
void	createDurableSubscriber(java.lang.String clientID, java.lang.String clientGroup, java.lang.String application, javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal, boolean priorityOrdering)	Create a JMS durable subscriber on the Broker.
void	createDurableSubscriber(java.lang.String clientID, java.lang.String clientGroup, java.lang.String application, javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal, boolean priorityOrdering, java.lang.String userDN, java.lang.String issuerDN)	Create a JMS durable subscriber on the Broker.
void	createDurableSubscriber(java.lang.String clientID, java.lang.String clientGroup, javax.jms.Topic topic, java.lang.String name, boolean priorityOrdering)	Create a JMS durable subscriber on the Broker.
void	createDurableSubscriber(java.lang.String clientID, java.lang.String clientGroup, javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal, boolean priorityOrdering)	Create a JMS durable subscriber on the Broker.
void	createDurableSubscriber(java.lang.String clientID, java.lang.String clientGroup, javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal, boolean priorityOrdering, java.lang.String userDN, java.lang.String issuerDN)	Create a JMS durable subscriber on the Broker.
void	createDurableSubscriber(javax.jms.ConnectionFactory factory, javax.jms.Topic topic, java.lang.String name)	Create a JMS durable subscriber on the Broker.
void	createDurableSubscriber(javax.jms.ConnectionFactory factory, javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal)	Create a JMS durable subscriber on the Broker.
void	createDurableSubscriber(javax.jms.ConnectionFactory factory, javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal, java.lang.String userDN, java.lang.String issuerDN)	Create a JMS durable subscriber on the Broker.
void	createEventType(java.lang.String eventType, java.lang.String description, int storage, int ttl, int validation)	Create an event type on the Broker.
void	createQueue(java.lang.String name, java.lang.String clientGroup, java.lang.String application, boolean sharedState, int sharedStateOrdering, boolean priorityOrdering)	Create the physical JMS queue on the Broker.
void	createQueue(java.lang.String name, java.lang.String clientGroup, java.lang.String application, boolean sharedState, int sharedStateOrdering, boolean priorityOrdering, java.lang.String userDN, java.lang.String issuerDN)	Create the physical JMS queue on the Broker.
void	createQueue(javax.jms.ConnectionFactory factory, javax.jms.Queue queue)	Create the physical JMS queue on the Broker.
void	createQueue(javax.jms.ConnectionFactory factory, javax.jms.Queue queue, java.lang.String userDN, java.lang.String issuerDN)	Create the physical JMS queue on the Broker.
void	createTerritory(java.lang.String territory)	Create a territory and add the Broker.
void	createTopic(java.lang.String topic)	Create a JMS topic on the Broker.
boolean	destinationExists(javax.jms.Destination destination)	Determine if the JMS destination exists on the Broker.
void	destroyBroker()	Destroy the current Broker.
void	destroyClient(java.lang.String client)	Destory a client on the Broker.
void	destroyClientGroup(java.lang.String clientGroup)	Destroy a client group from the Broker.
void	destroyDestination(javax.jms.Destination destination)	Destroy a JMS destination on the Broker.
void	destroyDurableSubscriber(java.lang.String clientID, java.lang.String name)	Destroy a JMS durable subscriber from the Broker.
void	destroyEventType(java.lang.String eventType)	Destroy an event type on the Broker.
void	destroyQueue(java.lang.String name)	Remove the physical JMS queue from the Broker.
void	destroyQueue(javax.jms.Queue queue)	Remove the physical JMS queue from the Broker.
void	destroyTopic(java.lang.String topic)	Destroy a JMS topic on the Broker.
boolean	durableSubscriberExists(java.lang.String clientID, java.lang.String name)	Determine if a JMS durable subscriber exists on the Broker.
boolean	eventTypeExists(java.lang.String eventType)	Determine if the event type exists on the Broker.
java.lang.String	getBroker()	Get the fully qualified Broker address to which the administration connection is connected.
java.lang.String	getBrokerHost()	Get the Broker Server host to which the administration connection is connected.
java.lang.String	getBrokerName()	Get the Broker name to which the administration connection is connected.
int	getBrokerPort()	Get the Broker Server port to which the administration connection is connected.
java.lang.String[]	getBrokers()	Get a list of Brokers on the current Broker Server.
java.lang.String[]	getClientGroups()	Get the list of client groups on the Broker.
java.lang.String[]	getClientGroups(java.lang.String sendPermission, java.lang.String receivePermission)	Get the list of client groups on the Broker.
java.lang.String[]	getClients()	Return the list of Broker clients.
java.lang.String[]	getClients(java.lang.String clientGroup, java.lang.String eventType)	Return the list of Broker clients.
java.lang.String[]	getClientSubscriptions(java.lang.String client)	Get the list of event types to which the client is subscribed.
java.lang.String	getDefaultBroker()	Get the default Broker on the current Broker Server.
java.lang.String[]	getEventTypes()	Get the list of event types on the Broker.
java.lang.String[]	getEventTypes(java.lang.String scope)	Get the list of event types on the Broker.
int	getPrepareTimeout()	Get the default prepare timeout.
int	getPrepareTimeoutAction()	Get the prepare timeout action.
java.lang.String[]	getReceivePermissions(java.lang.String clientGroup)	Get a client group's receive permissions.
int	getRecoverMode()	Gets the global recover mode of the Broker.
java.lang.String[]	getSendPermissions(java.lang.String clientGroup)	Get a client group's send permissions.
java.lang.String	getTerritory()	Get the Broker's territory.
java.lang.String[]	getTerritoryBrokerFullNames()	Get a list of Brokers in the current Broker's territory.
java.lang.String[]	getTerritoryBrokers()	Get a list of Brokers in the current Broker's territory.
int	getTransactionTimeout()	Get the default transaction timeout.
java.lang.String	getVersion()	Get the Broker Server version.
void	joinTerritory(java.lang.String host, java.lang.String name)	Join the Broker to the specified Broker's territory.
void	leaveTerritory()	Cause the Broker to leave its current territory.
boolean	queueExists(java.lang.String name)	Determine if the JMS queue exists on the Broker.
boolean	queueExists(javax.jms.Queue queue)	Determine if the JMS queue exists on the Broker.
void	removeReceivePermission(java.lang.String clientGroup, java.lang.String eventType)	Remove an event type from a client group's receive permissions.
void	removeReceivePermission(javax.jms.ConnectionFactory factory, javax.jms.Destination destination)	Remove a JMS destination from a connection factory's receive permissions.
void	removeSendPermission(java.lang.String clientGroup, java.lang.String eventType)	Remove an event type from a client group's send permissions.
void	removeSendPermission(javax.jms.ConnectionFactory factory, javax.jms.Destination destination)	Remove a JMS destination from a connection factory's send permissions.
void	setDefaultBroker(java.lang.String broker)	Set the default Broker on the current Broker Server.
void	setPrepareTimeout(int seconds)	Set the default prepare timeout.
void	setPrepareTimeoutAction(int action)	Set the prepare timeout action.
void	setReceivePermissions(java.lang.String clientGroup, java.lang.String[] permissions)	Set a client group's receive permissions.
void	setRecoverMode(int mode)	Sets the global recover mode of the Broker to either restricted (the default) or global.
void	setSendPermissions(java.lang.String clientGroup, java.lang.String[] permissions)	Set a client group's send permissions.
void	setTransactionTimeout(int seconds)	Set the default transaction timeout.
boolean	topicExists(java.lang.String topic)	Determine if the JMS topic exists on the Broker.

Methods inherited from class java.lang.Object

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

Field Detail

EVENT_TYPE_PLACEHOLDER

protected static final java.lang.String EVENT_TYPE_PLACEHOLDER

See Also:

Constant Field Values

MESSAGE_TYPE_PROPERTY

public static final java.lang.String MESSAGE_TYPE_PROPERTY

See Also:

Constant Field Values

Constructor Detail

WmJMSAdminImpl

protected WmJMSAdminImpl(java.lang.String brokerHost,
                         java.lang.String brokerName,
                         java.lang.String clientID,
                         java.lang.String clientGroup)
                  throws WmJMSAdminException

Throws:

WmJMSAdminException

WmJMSAdminImpl

protected WmJMSAdminImpl(java.lang.String brokerHost,
                         java.lang.String brokerName,
                         java.lang.String clientID,
                         java.lang.String clientGroup,
                         SSLInfo sslinfo)
                  throws WmJMSAdminException

Throws:

WmJMSAdminException

WmJMSAdminImpl

protected WmJMSAdminImpl(java.lang.String brokerHost,
                         java.lang.String brokerName,
                         java.lang.String clientID,
                         java.lang.String clientGroup,
                         java.lang.String userName,
                         java.lang.String password,
                         java.lang.String truststore,
                         boolean encryption)
                  throws WmJMSAdminException

Throws:

WmJMSAdminException

Method Detail

close

public void close()
           throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Closes the administration connection to the Broker.

Specified by:

close in interface WmJMSAdmin

Throws:

WmJMSAdminException - if an error occurs closing the connection to the Broker

getBrokerName

public java.lang.String getBrokerName()
                               throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the Broker name to which the administration connection is connected.

Specified by:

getBrokerName in interface WmJMSAdmin

Returns:

the Broker name

Throws:

WmJMSAdminException - if there are communication problems with the Broker

getBrokerHost

public java.lang.String getBrokerHost()
                               throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the Broker Server host to which the administration connection is connected.

Specified by:

getBrokerHost in interface WmJMSAdmin

Returns:

the Broker Server host

Throws:

WmJMSAdminException - if there are communication problems with the Broker

getBrokerPort

public int getBrokerPort()
                  throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the Broker Server port to which the administration connection is connected.

Specified by:

getBrokerPort in interface WmJMSAdmin

Returns:

the Broker Server port

Throws:

WmJMSAdminException - if there are communication problems with the Broker

getBroker

public java.lang.String getBroker()
                           throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the fully qualified Broker address to which the administration connection is connected.

Specified by:

getBroker in interface WmJMSAdmin

Returns:

the fully qualified Broker address

Throws:

WmJMSAdminException

getVersion

public java.lang.String getVersion()
                            throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the Broker Server version.

Specified by:

getVersion in interface WmJMSAdmin

Returns:

the Broker Server version

Throws:

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

getBrokers

public java.lang.String[] getBrokers()
                              throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get a list of Brokers on the current Broker Server.

Specified by:

getBrokers in interface WmJMSAdmin

Returns:

a list of Brokers on the current Broker Server

Throws:

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

createBroker

public void createBroker(java.lang.String broker,
                         java.lang.String description,
                         boolean makeDefault)
                  throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a Broker on the current Broker Server.

Specified by:

createBroker in interface WmJMSAdmin

Parameters:

broker - the Broker name

description - the Broker description

makeDefault - true to make the Broker the default Broker

Throws:

WmJMSAdminAlreadyExistsException - if the Broker already exists

WmJMSAdminInvalidNameException - if the Broker name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

destroyBroker

public void destroyBroker()
                   throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Destroy the current Broker.

Specified by:

destroyBroker in interface WmJMSAdmin

Throws:

WmJMSAdminSecurityException - if there are not sufficient permissions to destroy the Broker.

WmJMSAdminException

getDefaultBroker

public java.lang.String getDefaultBroker()
                                  throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the default Broker on the current Broker Server.

Specified by:

getDefaultBroker in interface WmJMSAdmin

Throws:

WmJMSAdminDoesNotExistException - if there is no default Broker

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

See Also:

WmJMSAdmin.setDefaultBroker(java.lang.String)

setDefaultBroker

public void setDefaultBroker(java.lang.String broker)
                      throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Set the default Broker on the current Broker Server.

Specified by:

setDefaultBroker in interface WmJMSAdmin

Parameters:

broker - the Broker to make default, or null to make no Broker default

Throws:

WmJMSAdminDoesNotExistException - if the Broker does not exist

WmJMSAdminInvalidNameException - if the Broker name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

See Also:

WmJMSAdmin.getDefaultBroker()

getTerritory

public java.lang.String getTerritory()
                              throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the Broker's territory.

Specified by:

getTerritory in interface WmJMSAdmin

Returns:

the Broker's territory

Throws:

WmJMSAdminDoesNotExistException - if the Broker is not in a territory

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

createTerritory

public void createTerritory(java.lang.String territory)
                     throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a territory and add the Broker.

Specified by:

createTerritory in interface WmJMSAdmin

Parameters:

territory - the territory to create

Throws:

WmJMSAdminInvalidNameException - if the territory name is invalid

WmJMSAdminAlreadyExistsException - if the Broker is already in a territory

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

joinTerritory

public void joinTerritory(java.lang.String host,
                          java.lang.String name)
                   throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Join the Broker to the specified Broker's territory.

Specified by:

joinTerritory in interface WmJMSAdmin

Parameters:

host - the host of the Broker whose territory is to be joined

name - the name of the Broker whose territory is to be joined

Throws:

WmJMSAdminInvalidNameException - if the Broker name is invalid

WmJMSAdminAlreadyExistsException - if the Broker is already in a territory

WmJMSAdminException - if the territory cannot be joined

WmJMSAdminSecurityException - if there are not sufficient permissions

leaveTerritory

public void leaveTerritory()
                    throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Cause the Broker to leave its current territory.

Specified by:

leaveTerritory in interface WmJMSAdmin

Throws:

WmJMSAdminDoesNotExistException - if the Broker is not currently in a territory

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

getTerritoryBrokers

public java.lang.String[] getTerritoryBrokers()
                                       throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get a list of Brokers in the current Broker's territory.

Specified by:

getTerritoryBrokers in interface WmJMSAdmin

Returns:

a list of Brokers in the current territory

Throws:

WmJMSAdminDoesNotExistException - if the Broker is not currently in a territory

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

getTerritoryBrokerFullNames

public java.lang.String[] getTerritoryBrokerFullNames()
                                               throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get a list of Brokers in the current Broker's territory.

Specified by:

getTerritoryBrokerFullNames in interface WmJMSAdmin

Returns:

a list of full names of Brokers (Ex BrokerA@localhost:6849) in the current territory

Throws:

WmJMSAdminDoesNotExistException - if the Broker is not currently in a territory

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

getClientGroups

public java.lang.String[] getClientGroups(java.lang.String sendPermission,
                                          java.lang.String receivePermission)
                                   throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the list of client groups on the Broker. The search can be refined by searching for only those client groups with a specifc send and/or receive permission.

Specified by:

getClientGroups in interface WmJMSAdmin

Parameters:

sendPermission - an event type to search on

receivePermission - an event type to search on

Returns:

the list of client group names on the Broker

Throws:

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

getClientGroups

public java.lang.String[] getClientGroups()
                                   throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the list of client groups on the Broker.

Specified by:

getClientGroups in interface WmJMSAdmin

Returns:

the list of client group names on the Broker

Throws:

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

clientGroupExists

public boolean clientGroupExists(java.lang.String clientGroup)
                          throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Determine if the specified client group exists on the Broker.

Specified by:

clientGroupExists in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

Returns:

true if the client group exists

Throws:

WmJMSAdminInvalidNameException - if the client group name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to get the client group

WmJMSAdminException

createClientGroup

public void createClientGroup(java.lang.String clientGroup,
                              int storage)
                       throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a client group on the Broker. A client group may be created with either persistent storage or volatile storage.

Specified by:

createClientGroup in interface WmJMSAdmin

Parameters:

clientGroup - the client group name to create

storage - either WmJMSAdmin.STORAGE_VOLATILE or WmJMSAdmin.STORAGE_GUARANTEED

Throws:

WmJMSAdminAlreadyExistsException - if the client group already exists

WmJMSAdminInvalidNameException - if the client group name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the client group

WmJMSAdminException

destroyClientGroup

public void destroyClientGroup(java.lang.String clientGroup)
                        throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Destroy a client group from the Broker.

Specified by:

destroyClientGroup in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

Throws:

WmJMSAdminInvalidNameException - if the client group name is invalid

WmJMSAdminDoesNotExistException - if the client group does not exist

WmJMSAdminDependsException - if there are client's that depend on this client group

WmJMSAdminSecurityException - if there are not sufficient permissions to destroy the client group

WmJMSAdminException

getSendPermissions

public java.lang.String[] getSendPermissions(java.lang.String clientGroup)
                                      throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get a client group's send permissions. The send permissions are the event type names that the client group has permission to send.

Specified by:

getSendPermissions in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

Returns:

the client group's send permissions

Throws:

WmJMSAdminInvalidNameException - if the client group name is invalid

WmJMSAdminDoesNotExistException - if the client group does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to get the client group's send permissions

WmJMSAdminException

setSendPermissions

public void setSendPermissions(java.lang.String clientGroup,
                               java.lang.String[] permissions)
                        throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Set a client group's send permissions. The send permissions are the event type names that the client group has permission to send.

Note: you cannot use multiple threads to simultaneously update permissions for document types on the same client group.

Specified by:

setSendPermissions in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

permissions - the client group's send permissions

Throws:

WmJMSAdminInvalidNameException - if the client group name or permission name is invalid

WmJMSAdminDoesNotExistException - if the client group or event type does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to set the client group's send permissions

WmJMSAdminException

getReceivePermissions

public java.lang.String[] getReceivePermissions(java.lang.String clientGroup)
                                         throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get a client group's receive permissions. The receive permissions are the event type names that the client group has permission to receive.

Specified by:

getReceivePermissions in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

Returns:

the client group's receive permissions

Throws:

WmJMSAdminInvalidNameException - if the client group name is invalid

WmJMSAdminDoesNotExistException - if the client group does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to get the client group's receive permissions

WmJMSAdminException

setReceivePermissions

public void setReceivePermissions(java.lang.String clientGroup,
                                  java.lang.String[] permissions)
                           throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Set a client group's receive permissions. The receive permissions are the event type names that the client group has permission to receive.

Note: you cannot use multiple threads to simultaneously update permissions for document types on the same client group.

Specified by:

setReceivePermissions in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

permissions - the client group's receive permissions

Throws:

WmJMSAdminInvalidNameException - if the client group name or permission name is invalid

WmJMSAdminDoesNotExistException - if the client group or event type does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to set the client group's receive permissions

WmJMSAdminException

addSendPermission

public void addSendPermission(java.lang.String clientGroup,
                              java.lang.String eventType)
                       throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Add an event type to a client group's send permissions.

Note: you cannot use multiple threads to simultaneously update permissions for document types on the same client group.

Specified by:

addSendPermission in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

eventType - the event type name to add

Throws:

WmJMSAdminInvalidNameException - if the client group name or event type is invalid

WmJMSAdminDoesNotExistException - if the client group or event type does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to add to the client group's send permissions

WmJMSAdminException

removeSendPermission

public void removeSendPermission(java.lang.String clientGroup,
                                 java.lang.String eventType)
                          throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Remove an event type from a client group's send permissions.

Note: you cannot use multiple threads to simultaneously update permissions for document types on the same client group.

Specified by:

removeSendPermission in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

eventType - the event type name to remove

Throws:

WmJMSAdminInvalidNameException - if the client group name is invalid

WmJMSAdminDoesNotExistException - if the client group does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to remove to the client group's send permissions

WmJMSAdminException

addReceivePermission

public void addReceivePermission(java.lang.String clientGroup,
                                 java.lang.String eventType)
                          throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Add an event type to a client group's receive permissions.

Note: you cannot use multiple threads to simultaneously update permissions for document types on the same client group.

Specified by:

addReceivePermission in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

eventType - the event type name to add

Throws:

WmJMSAdminInvalidNameException - if the client group name or event type is invalid

WmJMSAdminDoesNotExistException - if the client group or event type does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to add to the client group's receive permissions

WmJMSAdminException

removeReceivePermission

public void removeReceivePermission(java.lang.String clientGroup,
                                    java.lang.String eventType)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Remove an event type from a client group's receive permissions.

Note: you cannot use multiple threads to simultaneously update permissions for document types on the same client group.

Specified by:

removeReceivePermission in interface WmJMSAdmin

Parameters:

clientGroup - the client group name

eventType - the event type name to remove

Throws:

WmJMSAdminInvalidNameException - if the client group name is invalid

WmJMSAdminDoesNotExistException - if the client group does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to remove to the client group's receive permissions

WmJMSAdminException

getEventTypes

public java.lang.String[] getEventTypes(java.lang.String scope)
                                 throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the list of event types on the Broker. The list can be refined by specifying an optional scope to which the event types belong.

Specified by:

getEventTypes in interface WmJMSAdmin

Parameters:

scope - the optional event type scope, or null for all event types

Returns:

the list of event types on the Broker

Throws:

WmJMSAdminSecurityException - if there are not sufficient permissions to get the list of event types on the Broker

WmJMSAdminException

getEventTypes

public java.lang.String[] getEventTypes()
                                 throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the list of event types on the Broker.

Specified by:

getEventTypes in interface WmJMSAdmin

Returns:

the list of event types on the Broker

Throws:

WmJMSAdminSecurityException - if there are not sufficient permissions to get the list of event types on the Broker

WmJMSAdminException

eventTypeExists

public boolean eventTypeExists(java.lang.String eventType)
                        throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Determine if the event type exists on the Broker.

Specified by:

eventTypeExists in interface WmJMSAdmin

Parameters:

eventType - the event type name

Returns:

true if the event type exists

Throws:

WmJMSAdminInvalidNameException - if the event type name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to get the event type on the Broker

WmJMSAdminException

createEventType

public void createEventType(java.lang.String eventType,
                            java.lang.String description,
                            int storage,
                            int ttl,
                            int validation)
                     throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create an event type on the Broker.

Specified by:

createEventType in interface WmJMSAdmin

Parameters:

eventType - the event type name

description - the event type description

storage - either WmJMSAdmin.STORAGE_VOLATILE or WmJMSAdmin.STORAGE_GUARANTEED

ttl - time-to-live of the event, or 0 to disable event expiration

validation - one of WmJMSAdmin.VALIDATION_FULL, WmJMSAdmin.VALIDATION_OPEN or WmJMSAdmin.VALIDATION_NONE

Throws:

WmJMSAdminAlreadyExistsException - if the event type already exists

WmJMSAdminInvalidNameException - if the event type name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the event type on the Broker

WmJMSAdminException

destroyEventType

public void destroyEventType(java.lang.String eventType)
                      throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Destroy an event type on the Broker.

Specified by:

destroyEventType in interface WmJMSAdmin

Parameters:

eventType - the event type name

Throws:

WmJMSAdminInvalidNameException - if the event type name is invalid

WmJMSAdminDoesNotExistException - if the event type does not exist

WmJMSAdminDependsException - if there are permissions that depend on this event type

WmJMSAdminSecurityException - if there are not sufficient permissions to destroy the event type on the Broker

WmJMSAdminException

getClients

public java.lang.String[] getClients()
                              throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Return the list of Broker clients.

Specified by:

getClients in interface WmJMSAdmin

Returns:

the list of Broker clients

Throws:

WmJMSAdminSecurityException - if there are not sufficient permissions to get the list of Broker clients

WmJMSAdminException

getClients

public java.lang.String[] getClients(java.lang.String clientGroup,
                                     java.lang.String eventType)
                              throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Return the list of Broker clients. The search can be be refined by specifying only a certain client group and or subscription.

Specified by:

getClients in interface WmJMSAdmin

Parameters:

clientGroup - the optional client group to search on, or null to search on all client groups

eventType - the optional subscription to search on, or null to search on all subscriptions

Returns:

the list of Broker clients

Throws:

WmJMSAdminSecurityException - if there are not sufficient permissions to get the list of Broker clients

WmJMSAdminException

clientExists

public boolean clientExists(java.lang.String client)
                     throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Determine if a client exists on the Broker.

Specified by:

clientExists in interface WmJMSAdmin

Parameters:

client - the name of the client

Returns:

true if the client exists

Throws:

WmJMSAdminInvalidNameException - if the client name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to get the client

WmJMSAdminException

getClientSubscriptions

public java.lang.String[] getClientSubscriptions(java.lang.String client)
                                          throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the list of event types to which the client is subscribed.

Specified by:

getClientSubscriptions in interface WmJMSAdmin

Parameters:

client - the name of the client

Returns:

the list of subscriptions

Throws:

WmJMSAdminInvalidNameException - if the client name is invalid

WmJMSAdminDoesNotExistException - if the client does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions

WmJMSAdminException

clearClientQueue

public void clearClientQueue(java.lang.String client)
                      throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Clear a client's queue on the Broker.

Specified by:

clearClientQueue in interface WmJMSAdmin

Parameters:

client - the name of the client to clear

Throws:

WmJMSAdminInvalidNameException - if the client name is invalid

WmJMSAdminDoesNotExistException - if the client does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to clear the client's queue

WmJMSAdminException

closeClient

public void closeClient(java.lang.String client)
                 throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Close a client on the Broker.

Specified by:

closeClient in interface WmJMSAdmin

Parameters:

client - the name of the client to close on the Broker

Throws:

WmJMSAdminInvalidNameException - if the client name is invalid

WmJMSAdminDoesNotExistException - if the client does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to close the client

WmJMSAdminException

destroyClient

public void destroyClient(java.lang.String client)
                   throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Destory a client on the Broker.

Specified by:

destroyClient in interface WmJMSAdmin

Parameters:

client - the name of the client to destroy on the Broker

Throws:

WmJMSAdminInvalidNameException - if the client name is invalid

WmJMSAdminDoesNotExistException - if the client does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to destroy the client

WmJMSAdminException

setRecoverMode

public void setRecoverMode(int mode)
                    throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Sets the global recover mode of the Broker to either restricted (the default) or global. Restricted mode only allows a client to recover transactions to which it participated. Global mode allows a client to recover all recoverable transactions.

Specified by:

setRecoverMode in interface WmJMSAdmin

Parameters:

mode - The recover mode to set; either WmJMSAdmin.RECOVER_GLOBAL or WmJMSAdmin.RECOVER_RESTRICTED.

Throws:

WmJMSAdminException - if the recover mode could not be set

WmJMSAdminSecurityException - if there are not sufficient permissions

See Also:

WmJMSAdmin.getRecoverMode()

getRecoverMode

public int getRecoverMode()
                   throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Gets the global recover mode of the Broker.

Specified by:

getRecoverMode in interface WmJMSAdmin

Returns:

The recover mode; either WmJMSAdmin.RECOVER_GLOBAL or WmJMSAdmin.RECOVER_RESTRICTED.

Throws:

WmJMSAdminException - if the recover mode could not be retrieved

WmJMSAdminSecurityException - if there are not sufficient permissions

See Also:

WmJMSAdmin.setRecoverMode(int)

setPrepareTimeoutAction

public void setPrepareTimeoutAction(int action)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Set the prepare timeout action. This is the action the Broker will take when a prepared transaction times out.

Specified by:

setPrepareTimeoutAction in interface WmJMSAdmin

Parameters:

action - The action to set; either WmJMSAdmin.TRANSACTION_ROLLBACK or WmJMSAdmin.TRANSACTION_COMMIT.

Throws:

WmJMSAdminException - if the timeout action could not be set

WmJMSAdminSecurityException - if there are not sufficient permissions

See Also:

WmJMSAdmin.getPrepareTimeoutAction()

getPrepareTimeoutAction

public int getPrepareTimeoutAction()
                            throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the prepare timeout action. This is the action the Broker will take when a prepared transaction times out.

Specified by:

getPrepareTimeoutAction in interface WmJMSAdmin

Returns:

The prepare timeout action; either WmJMSAdmin.TRANSACTION_ROLLBACK or WmJMSAdmin.TRANSACTION_COMMIT.

Throws:

WmJMSAdminException - if the timeout action could not be retrieved

WmJMSAdminSecurityException - if there are not sufficient permissions

See Also:

WmJMSAdmin.setPrepareTimeoutAction(int)

setPrepareTimeout

public void setPrepareTimeout(int seconds)
                       throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Set the default prepare timeout. This is the default timeout period between when a transaction is prepared and before it is committed.

Specified by:

setPrepareTimeout in interface WmJMSAdmin

Parameters:

seconds - The prepare timeout in seconds, or -1 for infinite timeout.

Throws:

WmJMSAdminException - if the timeout could not be set

WmJMSAdminSecurityException - if there are not sufficient permissions

See Also:

WmJMSAdmin.getPrepareTimeout()

getPrepareTimeout

public int getPrepareTimeout()
                      throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the default prepare timeout. This is the default timeout period between when a transaction is prepared and before it is committed.

Specified by:

getPrepareTimeout in interface WmJMSAdmin

Returns:

The default prepare timeout in seconds.

Throws:

WmJMSAdminException - if the timeout could not be retrieved

WmJMSAdminSecurityException - if there are not sufficient permissions

See Also:

WmJMSAdmin.setPrepareTimeout(int)

setTransactionTimeout

public void setTransactionTimeout(int seconds)
                           throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Set the default transaction timeout.

Specified by:

setTransactionTimeout in interface WmJMSAdmin

Parameters:

seconds - The default transaction timeout to set.

Throws:

WmJMSAdminException - if the timeout could not be set

WmJMSAdminSecurityException - if there are not sufficient permissions

See Also:

WmJMSAdmin.getTransactionTimeout()

getTransactionTimeout

public int getTransactionTimeout()
                          throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Get the default transaction timeout.

Specified by:

getTransactionTimeout in interface WmJMSAdmin

Returns:

The default transaction timeout in seconds.

Throws:

WmJMSAdminException - if the timeout could not be retrieved

WmJMSAdminSecurityException - if there are not sufficient permissions

See Also:

WmJMSAdmin.setTransactionTimeout(int)

createConnectionFactory

public void createConnectionFactory(javax.jms.ConnectionFactory factory)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create the JMS connection factory on the Broker. This method will create the required client group on the Broker.

Specified by:

createConnectionFactory in interface WmJMSAdmin

Parameters:

factory - the factory to create on the Broker

Throws:

WmJMSAdminInvalidNameException - if the connection factory's client group name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the client group

WmJMSAdminException

connectionFactoryExists

public boolean connectionFactoryExists(javax.jms.ConnectionFactory factory)
                                throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Determines if the JMS connection factory exists on the Broker. This method determines if the connection factory's client group exists on the Broker.

Specified by:

connectionFactoryExists in interface WmJMSAdmin

Parameters:

factory - the connection factory

Returns:

true if the connection factory exists

Throws:

WmJMSAdminInvalidNameException - if the connection factory's client group name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to get the connection factory on the Broker.

WmJMSAdminException

destinationExists

public boolean destinationExists(javax.jms.Destination destination)
                          throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Determine if the JMS destination exists on the Broker. This method determines if the destination's event type exists on the Broker.

Specified by:

destinationExists in interface WmJMSAdmin

Parameters:

destination - the destination

Returns:

true if the destination exists

Throws:

WmJMSAdminInvalidNameException - if the destination name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to get the destination on the Broker.

WmJMSAdminException

createDestination

public void createDestination(javax.jms.Destination destination)
                       throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS destination on the Broker. This method will create the required event type on the Broker. If the destination is a queue the physical queue will NOT be created. Use WmJMSAdmin.createQueue(javax.jms.ConnectionFactory, javax.jms.Queue, java.lang.String, java.lang.String) to create the physical queue.

Specified by:

createDestination in interface WmJMSAdmin

Parameters:

destination - the destination to create on the Broker

Throws:

WmJMSAdminAlreadyExistsException - if the destination already exists

WmJMSAdminInvalidNameException - if the destination name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the destination on the Broker.

WmJMSAdminException

See Also:

WmJMSAdmin.createQueue(javax.jms.ConnectionFactory, javax.jms.Queue, java.lang.String, java.lang.String)

destroyDestination

public void destroyDestination(javax.jms.Destination destination)
                        throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Destroy a JMS destination on the Broker. This method will destroy the destination's event type on the Broker.

Specified by:

destroyDestination in interface WmJMSAdmin

Parameters:

destination - the destination to destroy on the Broker

Throws:

WmJMSAdminInvalidNameException - if the destination name is invalid

WmJMSAdminDoesNotExistException - if the destination does not exist

WmJMSAdminDependsException - if there are permissions that depend on this destination

WmJMSAdminSecurityException - if there are not sufficient permissions to destroy the destination on the Broker.

WmJMSAdminException

topicExists

public boolean topicExists(java.lang.String topic)
                    throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Determine if the JMS topic exists on the Broker. This method determines if the topic's event type exists on the Broker.

Specified by:

topicExists in interface WmJMSAdmin

Parameters:

topic - the topic

Returns:

true if the topic exists

Throws:

WmJMSAdminInvalidNameException - if the topic name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to get the topic on the Broker.

WmJMSAdminException

createTopic

public void createTopic(java.lang.String topic)
                 throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS topic on the Broker. This method will create the required event type on the Broker. If the topic is a queue the physical queue will NOT be created. Use WmJMSAdmin.createQueue(javax.jms.ConnectionFactory, javax.jms.Queue, java.lang.String, java.lang.String) to create the physical queue.

Specified by:

createTopic in interface WmJMSAdmin

Parameters:

topic - the topic to create on the Broker

Throws:

WmJMSAdminAlreadyExistsException - if the topic already exists

WmJMSAdminInvalidNameException - if the topic name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the topic on the Broker.

WmJMSAdminException

See Also:

WmJMSAdmin.createQueue(javax.jms.ConnectionFactory, javax.jms.Queue, java.lang.String, java.lang.String)

destroyTopic

public void destroyTopic(java.lang.String topic)
                  throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Destroy a JMS topic on the Broker. This method will destroy the topic's event type on the Broker.

Specified by:

destroyTopic in interface WmJMSAdmin

Parameters:

topic - the topic to destroy on the Broker

Throws:

WmJMSAdminInvalidNameException - if the topic name is invalid

WmJMSAdminDoesNotExistException - if the topic does not exist

WmJMSAdminDependsException - if there are permissions that depend on this topic

WmJMSAdminSecurityException - if there are not sufficient permissions to destroy the topic on the Broker.

WmJMSAdminException

addSendPermission

public void addSendPermission(javax.jms.ConnectionFactory factory,
                              javax.jms.Destination destination)
                       throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Add a JMS destination to a connection factory's send permissions. This method will add the destination's event type to the connection factory client group's send permissions.

Specified by:

addSendPermission in interface WmJMSAdmin

Parameters:

factory - the connection factory

destination - the destination to add to the permissions

Throws:

WmJMSAdminInvalidNameException - if the client group name or destination is invalid

WmJMSAdminDoesNotExistException - if the client group or destination does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to modify to the client group's send permissions

WmJMSAdminException

removeSendPermission

public void removeSendPermission(javax.jms.ConnectionFactory factory,
                                 javax.jms.Destination destination)
                          throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Remove a JMS destination from a connection factory's send permissions. This method will remove the destination's event type from the connection factory client group's send permissions.

Specified by:

removeSendPermission in interface WmJMSAdmin

Parameters:

factory - the connection factory

destination - the destination to remove from the permissions

Throws:

WmJMSAdminInvalidNameException - if the client group name is invalid

WmJMSAdminDoesNotExistException - if the client group does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to modify to the client group's send permissions

WmJMSAdminException

addReceivePermission

public void addReceivePermission(javax.jms.ConnectionFactory factory,
                                 javax.jms.Destination destination)
                          throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Add a JMS destination to a connection factory's receive permissions. This method will add the destination's event type to the connection factory client group's receive permissions.

Specified by:

addReceivePermission in interface WmJMSAdmin

Parameters:

factory - the connection factory

destination - the destination to add to the permissions

Throws:

WmJMSAdminInvalidNameException - if the client group name or destination is invalid

WmJMSAdminDoesNotExistException - if the client group or destination does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to modify to the client group's send permissions

WmJMSAdminException

removeReceivePermission

public void removeReceivePermission(javax.jms.ConnectionFactory factory,
                                    javax.jms.Destination destination)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Remove a JMS destination from a connection factory's receive permissions. This method will remove the destination's event type from the connection factory client group's receive permissions.

Specified by:

removeReceivePermission in interface WmJMSAdmin

Parameters:

factory - the connection factory

destination - the destination to remove from the permissions

Throws:

WmJMSAdminInvalidNameException - if the client group name is invalid

WmJMSAdminDoesNotExistException - if the client group does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to modify to the client group's send permissions

WmJMSAdminException

durableSubscriberExists

public boolean durableSubscriberExists(java.lang.String clientID,
                                       java.lang.String name)
                                throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Determine if a JMS durable subscriber exists on the Broker.

Specified by:

durableSubscriberExists in interface WmJMSAdmin

Parameters:

clientID - the client ID of the connection

name - the subscription name

Returns:

true if the durable subscription exists

Throws:

WmJMSAdminInvalidNameException - if the client ID or subscription name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to get the durable subscriber on the Broker.

WmJMSAdminException

createDurableSubscriber

public void createDurableSubscriber(javax.jms.ConnectionFactory factory,
                                    javax.jms.Topic topic,
                                    java.lang.String name,
                                    java.lang.String selector,
                                    boolean noLocal)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS durable subscriber on the Broker. The connection factory provides the location, client group and the client ID of the durable subscriber to create.

Specified by:

createDurableSubscriber in interface WmJMSAdmin

Parameters:

factory - the connection factory to use to create the durable subscriber

topic - the topic on which to subscribe

name - the subscription name

selector - an optional selector, or null

noLocal - the no local flag

Throws:

WmJMSAdminAlreadyExistsException - if the durable subscription already exists

WmJMSAdminInvalidNameException - if the client ID, destination name or subscription name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the durable subscriber on the Broker.

WmJMSAdminException

createDurableSubscriber

public void createDurableSubscriber(javax.jms.ConnectionFactory factory,
                                    javax.jms.Topic topic,
                                    java.lang.String name,
                                    java.lang.String selector,
                                    boolean noLocal,
                                    java.lang.String userDN,
                                    java.lang.String issuerDN)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS durable subscriber on the Broker. The connection factory provides the location, client group and the client ID of the durable subscriber to create.

Specified by:

createDurableSubscriber in interface WmJMSAdmin

Parameters:

factory - the connection factory to use to create the durable subscriber

topic - the topic on which to subscribe

name - the subscription name

selector - an optional selector, or null

noLocal - the no local flag

userDN - the distinguished name of the intended user

issuerDN - the distinguished name of the intended user's issuer

Throws:

WmJMSAdminAlreadyExistsException - if the durable subscription already exists

WmJMSAdminInvalidNameException - if the client ID, destination name or subscription name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the durable subscriber on the Broker.

WmJMSAdminException

createDurableSubscriber

public void createDurableSubscriber(java.lang.String clientID,
                                    java.lang.String clientGroup,
                                    javax.jms.Topic topic,
                                    java.lang.String name,
                                    java.lang.String selector,
                                    boolean noLocal,
                                    boolean priorityOrdering)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS durable subscriber on the Broker.

Specified by:

createDurableSubscriber in interface WmJMSAdmin

Parameters:

clientID - the client ID to use to create the durable subscriber

clientGroup - the client group to use to create the durable subscriber

topic - the topic on which to subscribe

name - the subscription name

selector - an optional selector, or null

noLocal - the no local flag

priorityOrdering - true to create a durable subscriber with priority ordering

Throws:

WmJMSAdminAlreadyExistsException - if the durable subscription already exists

WmJMSAdminInvalidNameException - if the client ID, destination name or subscription name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the durable subscriber on the Broker.

WmJMSAdminException

createDurableSubscriber

public void createDurableSubscriber(java.lang.String clientID,
                                    java.lang.String clientGroup,
                                    javax.jms.Topic topic,
                                    java.lang.String name,
                                    boolean priorityOrdering)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS durable subscriber on the Broker.

Specified by:

createDurableSubscriber in interface WmJMSAdmin

Parameters:

clientID - the client ID to use to create the durable subscriber

clientGroup - the client group to use to create the durable subscriber

topic - the topic on which to subscribe

name - the subscription name

priorityOrdering - true to create a durable subscriber with priority ordering

Throws:

WmJMSAdminAlreadyExistsException - if the durable subscription already exists

WmJMSAdminInvalidNameException - if the client ID, destination name or subscription name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the durable subscriber on the Broker.

WmJMSAdminException

createDurableSubscriber

public void createDurableSubscriber(java.lang.String clientID,
                                    java.lang.String clientGroup,
                                    javax.jms.Topic topic,
                                    java.lang.String name,
                                    java.lang.String selector,
                                    boolean noLocal,
                                    boolean priorityOrdering,
                                    java.lang.String userDN,
                                    java.lang.String issuerDN)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS durable subscriber on the Broker.

Specified by:

createDurableSubscriber in interface WmJMSAdmin

Parameters:

clientID - the client ID to use to create the durable subscriber

clientGroup - the client group to use to create the durable subscriber

topic - the topic on which to subscribe

name - the subscription name

selector - an optional selector, or null

noLocal - the no local flag

priorityOrdering - true to create a durable subscriber with priority ordering

userDN - the distinguished name of the intended user

issuerDN - the distinguished name of the intended user's issuer

Throws:

WmJMSAdminAlreadyExistsException - if the durable subscription already exists

WmJMSAdminInvalidNameException - if the client ID, destination name or subscription name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the durable subscriber on the Broker.

WmJMSAdminException

createDurableSubscriber

public void createDurableSubscriber(java.lang.String clientID,
                                    java.lang.String clientGroup,
                                    java.lang.String application,
                                    javax.jms.Topic topic,
                                    java.lang.String name,
                                    java.lang.String selector,
                                    boolean noLocal,
                                    boolean priorityOrdering)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS durable subscriber on the Broker.

Specified by:

createDurableSubscriber in interface WmJMSAdmin

Parameters:

clientID - the client ID to use to create the durable subscriber

clientGroup - the client group to use to create the durable subscriber

application - an optional application name for display purposes

topic - the topic on which to subscribe

name - the subscription name

selector - an optional selector, or null

noLocal - the no local flag

priorityOrdering - true to create a durable subscriber with priority ordering

Throws:

WmJMSAdminAlreadyExistsException - if the durable subscription already exists

WmJMSAdminInvalidNameException - if the client ID, destination name or subscription name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the durable subscriber on the Broker.

WmJMSAdminException

createDurableSubscriber

public void createDurableSubscriber(java.lang.String clientID,
                                    java.lang.String clientGroup,
                                    java.lang.String application,
                                    javax.jms.Topic topic,
                                    java.lang.String name,
                                    java.lang.String selector,
                                    boolean noLocal,
                                    boolean priorityOrdering,
                                    java.lang.String userDN,
                                    java.lang.String issuerDN)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS durable subscriber on the Broker.

Specified by:

createDurableSubscriber in interface WmJMSAdmin

Parameters:

clientID - the client ID to use to create the durable subscriber

clientGroup - the client group to use to create the durable subscriber

application - an optional application name for display purposes

topic - the topic on which to subscribe

name - the subscription name

selector - an optional selector, or null

noLocal - the no local flag

priorityOrdering - true to create a durable subscriber with priority ordering

userDN - the distinguished name of the intended user

issuerDN - the distinguished name of the intended user's issuer

Throws:

WmJMSAdminAlreadyExistsException - if the durable subscription already exists

WmJMSAdminInvalidNameException - if the client ID, destination name or subscription name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the durable subscriber on the Broker.

WmJMSAdminException

createDurableSubscriber

public void createDurableSubscriber(javax.jms.ConnectionFactory factory,
                                    javax.jms.Topic topic,
                                    java.lang.String name)
                             throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create a JMS durable subscriber on the Broker. The connection factory provides the location, client group and the client ID of the durable subscriber to create.

Specified by:

createDurableSubscriber in interface WmJMSAdmin

Parameters:

factory - the connection factory to use to create the durable subscriber

topic - the topic on which to subscribe

name - the subscription name

Throws:

WmJMSAdminAlreadyExistsException - if the durable subscription already exists

WmJMSAdminInvalidNameException - if the client ID, destination name or subscription name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to create the durable subscriber on the Broker.

WmJMSAdminException

destroyDurableSubscriber

public void destroyDurableSubscriber(java.lang.String clientID,
                                     java.lang.String name)
                              throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Destroy a JMS durable subscriber from the Broker.

Specified by:

destroyDurableSubscriber in interface WmJMSAdmin

Parameters:

clientID - the client ID of the connection

name - the subscription name

Throws:

WmJMSAdminInvalidNameException - if the client ID or subscription name is invalid

WmJMSAdminDoesNotExistException - if the durable subscription does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to destroy the durable subscriber on the Broker.

WmJMSAdminException

clearDurableSubscriber

public void clearDurableSubscriber(java.lang.String clientID,
                                   java.lang.String name)
                            throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Clear all messages for a JMS durable subscriber on the Broker.

Specified by:

clearDurableSubscriber in interface WmJMSAdmin

Parameters:

clientID - the client ID of the connection

name - the subscription name

Throws:

WmJMSAdminInvalidNameException - if the client ID or subscription name is invalid

WmJMSAdminDoesNotExistException - if the durable subscription does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to clear the durable subscriber on the Broker.

WmJMSAdminException

queueExists

public boolean queueExists(java.lang.String name)
                    throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Determine if the JMS queue exists on the Broker.

Specified by:

queueExists in interface WmJMSAdmin

Parameters:

name - the queue name

Returns:

true if the queue exists

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to get the queue on the Broker.

WmJMSAdminException

queueExists

public boolean queueExists(javax.jms.Queue queue)
                    throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Determine if the JMS queue exists on the Broker.

Specified by:

queueExists in interface WmJMSAdmin

Parameters:

queue - the queue

Returns:

true if the queue exists

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminSecurityException - if there are not sufficient permissions to get the queue on the Broker.

WmJMSAdminException

createQueue

public void createQueue(javax.jms.ConnectionFactory factory,
                        javax.jms.Queue queue)
                 throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create the physical JMS queue on the Broker. The connection factory provides the location and client group of the queue to create.

Specified by:

createQueue in interface WmJMSAdmin

Parameters:

factory - the connection factory to use to create the queue

queue - the queue

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminAlreadyExistsException - if the queue already exists

WmJMSAdminSecurityException - if there are not sufficient permissions to create the queue on the Broker.

WmJMSAdminException

createQueue

public void createQueue(javax.jms.ConnectionFactory factory,
                        javax.jms.Queue queue,
                        java.lang.String userDN,
                        java.lang.String issuerDN)
                 throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create the physical JMS queue on the Broker. The connection factory provides the location and client group of the queue to create.

Specified by:

createQueue in interface WmJMSAdmin

Parameters:

factory - the connection factory to use to create the queue

queue - the queue

userDN - the distinguished name of the intended user

issuerDN - the distinguished name of the intended user's issuer

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminAlreadyExistsException - if the queue already exists

WmJMSAdminSecurityException - if there are not sufficient permissions to create the queue on the Broker.

WmJMSAdminException

createQueue

public void createQueue(java.lang.String name,
                        java.lang.String clientGroup,
                        java.lang.String application,
                        boolean sharedState,
                        int sharedStateOrdering,
                        boolean priorityOrdering)
                 throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create the physical JMS queue on the Broker.

Specified by:

createQueue in interface WmJMSAdmin

Parameters:

name - the queue to create

clientGroup - the client group to use to create the queue

application - an optional application name for display purposes

sharedState - true to create a shared state queue

sharedStateOrdering - either WmDestination.SHARED_STATE_ORDERING_NONE or WmDestination.SHARED_STATE_ORDERING_PUBLISHER

priorityOrdering - true to create a queue with priority ordering

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminAlreadyExistsException - if the queue already exists

WmJMSAdminSecurityException - if there are not sufficient permissions to create the queue on the Broker.

WmJMSAdminException

createQueue

public void createQueue(java.lang.String name,
                        java.lang.String clientGroup,
                        java.lang.String application,
                        boolean sharedState,
                        int sharedStateOrdering,
                        boolean priorityOrdering,
                        java.lang.String userDN,
                        java.lang.String issuerDN)
                 throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Create the physical JMS queue on the Broker.

Specified by:

createQueue in interface WmJMSAdmin

Parameters:

name - the queue to create

clientGroup - the client group to use to create the queue

application - an optional application name for display purposes

sharedState - true to create a shared state queue

sharedStateOrdering - either WmDestination.SHARED_STATE_ORDERING_NONE or WmDestination.SHARED_STATE_ORDERING_PUBLISHER

priorityOrdering - true to create a queue with priority ordering

userDN - the distinguished name of the intended user

issuerDN - the distinguished name of the intended user's issuer

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminAlreadyExistsException - if the queue already exists

WmJMSAdminSecurityException - if there are not sufficient permissions to create the queue on the Broker.

WmJMSAdminException

destroyQueue

public void destroyQueue(java.lang.String name)
                  throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Remove the physical JMS queue from the Broker.

Specified by:

destroyQueue in interface WmJMSAdmin

Parameters:

name - the queue name to remove

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminDoesNotExistException - if the queue does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to remove the queue from the Broker.

WmJMSAdminException

destroyQueue

public void destroyQueue(javax.jms.Queue queue)
                  throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Remove the physical JMS queue from the Broker.

Specified by:

destroyQueue in interface WmJMSAdmin

Parameters:

queue - the queue to remove

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminDoesNotExistException - if the queue does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to remove the queue from the Broker.

WmJMSAdminException

clearQueue

public void clearQueue(java.lang.String name)
                throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Clear all messages for a JMS queue on the Broker.

Specified by:

clearQueue in interface WmJMSAdmin

Parameters:

name - the queue name

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminDoesNotExistException - if the queue does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to clear the queue on the Broker.

WmJMSAdminException

clearQueue

public void clearQueue(javax.jms.Queue queue)
                throws WmJMSAdminException

Description copied from interface: WmJMSAdmin

Clear all messages for a JMS queue on the Broker.

Specified by:

clearQueue in interface WmJMSAdmin

Parameters:

queue - the queue to clear

Throws:

WmJMSAdminInvalidNameException - if the queue name is invalid

WmJMSAdminDoesNotExistException - if the queue does not exist

WmJMSAdminSecurityException - if there are not sufficient permissions to clear the queue on the Broker.

WmJMSAdminException