public class TransportManager
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
int |
getMaxMessageSize(ObjectQ.Vendor vendor)
Get the maximum message size for a vendor.
|
Transport |
getTransport(ObjectQ.Vendor vendor)
Get the transport for this vendor.
|
Transport |
getTransport(java.lang.String service)
Get the transport for this service.
|
ObjectQ.Vendor |
getVendor(java.lang.String service)
Get the vendor for a service.
|
Handle |
registerPrimary(ObjectQ.Vendor vendor)
Register an unnamed primary queue.
|
Handle |
registerPrimary(java.lang.String service)
Register a named primary queue.
|
Handle |
registerPrimaryAlias(ObjectQ.Vendor vendor,
java.lang.String alias)
Register a named primary queue.
|
Handle |
registerPrimaryQueue(ObjectQ.Vendor vendor,
java.lang.String queue)
Register a named primary queue.
|
Handle |
registerSecondary(ObjectQ.Vendor vendor)
Register an unnamed secondary queue.
|
Handle |
registerSecondary(java.lang.String service)
Register a named secondary queue.
|
Handle |
registerSecondaryAlias(ObjectQ.Vendor vendor,
java.lang.String alias)
Register a named secondary queue.
|
Handle |
registerSecondaryQueue(ObjectQ.Vendor vendor,
java.lang.String queue)
Register a named secondary queue.
|
void |
setMaxMessageSize(ObjectQ.Vendor vendor,
int size)
Set the maximum message size for a vendor
|
void |
setResource(Resource resource,
ObjectQ.Vendor vendor)
Set the Resource for a vendor's transport.
|
java.lang.String |
toString() |
void |
unregisterPrimary(ObjectQ.Vendor vendor)
Unregister the primary queue.
|
void |
unregisterPrimary(java.lang.String service)
Unregister the primary queue.
|
void |
unregisterSecondary(ObjectQ.Vendor vendor,
Handle handle)
Unregister a secondary queue.
|
public int getMaxMessageSize(ObjectQ.Vendor vendor)
vendor
- The vendor (JMS).public Transport getTransport(ObjectQ.Vendor vendor)
vendor
- The vendor (JMS).public Transport getTransport(java.lang.String service)
service
- The service (eg, "Demo.Sales").public ObjectQ.Vendor getVendor(java.lang.String service)
service
- The service (eg, "Demo.Sales").public Handle registerPrimary(ObjectQ.Vendor vendor) throws javax.naming.NamingException, VendorTransportException
vendor
- The transport vendor (JMS).javax.naming.NamingException
- The property jmsQCF could not be found, or was incorrect.VendorTransportException
- Use getErrorCode() to determine the cause.public Handle registerPrimary(java.lang.String service) throws javax.naming.NamingException, VendorTransportException
service
- The service represented by the queue (eg, "Demo.Sales").javax.naming.NamingException
- The property jmsQCF could not be found, or was incorrect.VendorTransportException
- Use getErrorCode() to determine the cause.public Handle registerPrimaryAlias(ObjectQ.Vendor vendor, java.lang.String alias) throws javax.naming.NamingException, VendorTransportException
vendor
- The transport vendor (JMS).alias
- The queue alias, corresponding to an entry in JNDI.javax.naming.NamingException
- The alias could not be found.VendorTransportException
- Use getErrorCode() to determine the cause.public Handle registerPrimaryQueue(ObjectQ.Vendor vendor, java.lang.String queue) throws javax.naming.NamingException, VendorTransportException
vendor
- The transport vendor (JMS).queue
- The queue name, corresponding to vendor transport queue (eg, "MYQUEUE").javax.naming.NamingException
- The property jmsQCF could not be found, or was incorrect.VendorTransportException
- Use getErrorCode() to determine the cause.public Handle registerSecondary(ObjectQ.Vendor vendor) throws NotConnectedException, VendorTransportException
vendor
- The transport vendor (JMS).NotConnectedException
- registerPrimary() must be called first to establish
a connection to the underlying vendor transport.VendorTransportException
- Use getErrorCode() to determine the cause.public Handle registerSecondary(java.lang.String service) throws NotConnectedException, VendorTransportException
service
- The service represented by the queue (eg, "Demo.Sales").NotConnectedException
- registerPrimary() must be called first to establish
a connection to the underlying vendor transport.VendorTransportException
- Use getErrorCode() to determine the cause.public Handle registerSecondaryAlias(ObjectQ.Vendor vendor, java.lang.String alias) throws NotConnectedException, javax.naming.NamingException, VendorTransportException
vendor
- The transport vendor (JMS).alias
- The queue alias, corresponding to an entry in JNDI.javax.naming.NamingException
- The alias could not be found.NotConnectedException
- registerPrimary() must be called first to establish
a connection to the underlying vendor transport.VendorTransportException
- Use getErrorCode() to determine the cause.public Handle registerSecondaryQueue(ObjectQ.Vendor vendor, java.lang.String queue) throws NotConnectedException, VendorTransportException
vendor
- The transport vendor (JMS).queue
- The queue name, corresponding to vendor transport queue (eg, "MYQUEUE").NotConnectedException
- registerPrimary() must be called first to establish
a connection to the underlying vendor transport.VendorTransportException
- Use getErrorCode() to determine the cause.public void setMaxMessageSize(ObjectQ.Vendor vendor, int size)
vendor
- The vendor (JMS).size
- The maximum message size.public void setResource(Resource resource, ObjectQ.Vendor vendor)
resource
- The resource.vendor
- The vendor (JMS).public java.lang.String toString()
toString
in class java.lang.Object
public void unregisterPrimary(ObjectQ.Vendor vendor)
vendor
- The transport vendor (JMS).public void unregisterPrimary(java.lang.String service)
service
- The service represented by this queue (eg, "Demo.Sales").public void unregisterSecondary(ObjectQ.Vendor vendor, Handle handle)
vendor
- The transport vendor (JMS).handle
- The handle of the secondary queue.