public class Publisher extends Object implements Closeable
Constructor and Description |
---|
Publisher(boolean useProps,
String initialContextFactory,
String providerUrl,
String connfactory,
String destinationName,
boolean useAuth,
String securityPrincipal,
String securityCredentials)
Create a publisher using either the jndi.properties file or the provided parameters.
|
Publisher(boolean useProps,
String initialContextFactory,
String providerUrl,
String connfactory,
String destinationName,
boolean useAuth,
String securityPrincipal,
String securityCredentials,
boolean useNonPersistentMessages)
Create a publisher using either the jndi.properties file or the provided parameters.
|
Publisher(boolean useProps,
String initialContextFactory,
String providerUrl,
String connfactory,
String destinationName,
boolean useAuth,
String securityPrincipal,
String securityCredentials,
boolean staticDestination,
boolean useNonPersistentMessages)
Create a publisher using either the jndi.properties file or the provided parameters
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close will close the session
|
Message |
publish(byte[] bytes,
String destinationName,
Map<String,Object> properties) |
Message |
publish(Map<String,Object> map) |
Message |
publish(Map<String,Object> map,
String destinationName) |
MapMessage |
publish(Map<String,Object> map,
String destinationName,
Map<String,Object> properties) |
Message |
publish(Serializable contents) |
Message |
publish(Serializable contents,
String destinationName) |
Message |
publish(Serializable contents,
String destinationName,
Map<String,Object> properties) |
Message |
publish(String text) |
Message |
publish(String text,
String destinationName) |
Message |
publish(String text,
String destinationName,
Map<String,Object> properties) |
public Publisher(boolean useProps, String initialContextFactory, String providerUrl, String connfactory, String destinationName, boolean useAuth, String securityPrincipal, String securityCredentials) throws JMSException, NamingException
useProps
- true if a jndi.properties file is to be usedinitialContextFactory
- the (ignored if useProps is true)providerUrl
- (ignored if useProps is true)connfactory
- destinationName
- useAuth
- (ignored if useProps is true)securityPrincipal
- (ignored if useProps is true)securityCredentials
- (ignored if useProps is true)JMSException
- if the context could not be initialised, or there was some other errorNamingException
public Publisher(boolean useProps, String initialContextFactory, String providerUrl, String connfactory, String destinationName, boolean useAuth, String securityPrincipal, String securityCredentials, boolean useNonPersistentMessages) throws JMSException, NamingException
useProps
- true if a jndi.properties file is to be usedinitialContextFactory
- the (ignored if useProps is true)providerUrl
- (ignored if useProps is true)connfactory
- destinationName
- useAuth
- (ignored if useProps is true)securityPrincipal
- (ignored if useProps is true)securityCredentials
- (ignored if useProps is true)useNonPersistentMessages
- Flag Delivery Mode as Non persistent if trueJMSException
- if the context could not be initialised, or there was some other errorNamingException
public Publisher(boolean useProps, String initialContextFactory, String providerUrl, String connfactory, String destinationName, boolean useAuth, String securityPrincipal, String securityCredentials, boolean staticDestination, boolean useNonPersistentMessages) throws JMSException, NamingException
useProps
- true if a jndi.properties file is to be usedinitialContextFactory
- the (ignored if useProps is true)providerUrl
- (ignored if useProps is true)connfactory
- destinationName
- useAuth
- (ignored if useProps is true)securityPrincipal
- (ignored if useProps is true)securityCredentials
- (ignored if useProps is true)staticDestination
- true is the destination is not to change between loopsuseNonPersistentMessages
- Flag Delivery Mode as Non persistent if trueJMSException
- if the context could not be initialised, or there was some other errorNamingException
public Message publish(String text) throws JMSException, NamingException
JMSException
NamingException
public Message publish(String text, String destinationName) throws JMSException, NamingException
JMSException
NamingException
public Message publish(String text, String destinationName, Map<String,Object> properties) throws JMSException, NamingException
JMSException
NamingException
public Message publish(Serializable contents) throws JMSException, NamingException
JMSException
NamingException
public Message publish(Serializable contents, String destinationName) throws JMSException, NamingException
JMSException
NamingException
public Message publish(Serializable contents, String destinationName, Map<String,Object> properties) throws JMSException, NamingException
JMSException
NamingException
public Message publish(byte[] bytes, String destinationName, Map<String,Object> properties) throws JMSException, NamingException
JMSException
NamingException
public Message publish(Map<String,Object> map) throws JMSException, NamingException
JMSException
NamingException
public Message publish(Map<String,Object> map, String destinationName) throws JMSException, NamingException
JMSException
NamingException
public MapMessage publish(Map<String,Object> map, String destinationName, Map<String,Object> properties) throws JMSException, NamingException
JMSException
NamingException
public void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 1998-2014 Apache Software Foundation. All Rights Reserved.