Class Publisher
- java.lang.Object
-
- org.apache.jmeter.protocol.jms.client.Publisher
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
public class Publisher extends Object implements Closeable
-
-
Constructor Summary
Constructors Constructor 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 staticDestination)
Create a publisher using either the jndi.properties file or the provided parameters
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Close will close the sessionMessage
publish(byte[] bytes, String destinationName, Map<String,Object> properties, int deliveryMode, int priority, long expiration)
Message
publish(Serializable contents, String destinationName, Map<String,Object> properties, int deliveryMode, int priority, long expiration)
Message
publish(String text, String destinationName, Map<String,Object> properties, int deliveryMode, int priority, long expiration)
MapMessage
publish(Map<String,Object> map, String destinationName, Map<String,Object> properties, int deliveryMode, int priority, long expiration)
-
-
-
Constructor Detail
-
Publisher
public Publisher(boolean useProps, String initialContextFactory, String providerUrl, String connfactory, String destinationName, boolean useAuth, String securityPrincipal, String securityCredentials) throws JMSException, NamingException
Create a publisher using either the jndi.properties file or the provided parameters. Uses a static destination and persistent messages(for backward compatibility)- Parameters:
useProps
- true if a jndi.properties file is to be usedinitialContextFactory
- the (ignored if useProps is true)providerUrl
- (ignored if useProps is true)connfactory
- name of the object factory to look up in contextdestinationName
- name of the destination to useuseAuth
- (ignored if useProps is true)securityPrincipal
- (ignored if useProps is true)securityCredentials
- (ignored if useProps is true)- Throws:
JMSException
- if the context could not be initialised, or there was some other errorNamingException
- when creation of the publisher fails
-
Publisher
public Publisher(boolean useProps, String initialContextFactory, String providerUrl, String connfactory, String destinationName, boolean useAuth, String securityPrincipal, String securityCredentials, boolean staticDestination) throws JMSException, NamingException
Create a publisher using either the jndi.properties file or the provided parameters- Parameters:
useProps
- true if a jndi.properties file is to be usedinitialContextFactory
- the (ignored if useProps is true)providerUrl
- (ignored if useProps is true)connfactory
- name of the object factory to lookup in contextdestinationName
- name of the destination to useuseAuth
- (ignored if useProps is true)securityPrincipal
- (ignored if useProps is true)securityCredentials
- (ignored if useProps is true)staticDestination
- true if the destination is not to change between loops- Throws:
JMSException
- if the context could not be initialised, or there was some other errorNamingException
- when creation of the publisher fails
-
-
Method Detail
-
publish
public Message publish(String text, String destinationName, Map<String,Object> properties, int deliveryMode, int priority, long expiration) throws JMSException, NamingException
- Throws:
JMSException
NamingException
-
publish
public Message publish(Serializable contents, String destinationName, Map<String,Object> properties, int deliveryMode, int priority, long expiration) throws JMSException, NamingException
- Throws:
JMSException
NamingException
-
publish
public Message publish(byte[] bytes, String destinationName, Map<String,Object> properties, int deliveryMode, int priority, long expiration) throws JMSException, NamingException
- Throws:
JMSException
NamingException
-
publish
public MapMessage publish(Map<String,Object> map, String destinationName, Map<String,Object> properties, int deliveryMode, int priority, long expiration) throws JMSException, NamingException
- Throws:
JMSException
NamingException
-
close
public void close()
Close will close the session- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
-
-