org.apache.activemq.artemis.rest.queue

Class PostMessage

java.lang.Object

org.apache.activemq.artemis.rest.queue.PostMessage

Direct Known Subclasses:

PostMessageDupsOk, PostMessageNoDups

public class PostMessage
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	PostMessage.Pooled

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	defaultDurable
protected String	destination
protected ArrayBlockingQueue<PostMessage.Pooled>	pool
protected int	poolSize
protected long	producerTimeToLive
protected DestinationServiceManager	serviceManager
protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory	sessionFactory

Constructor Summary

Constructors

Constructor and Description
PostMessage()

Method Summary

Modifier and Type	Method and Description
protected void	addPooled()
void	cleanup()
protected org.apache.activemq.artemis.api.core.client.ClientMessage	createActiveMQMessage(javax.ws.rs.core.HttpHeaders headers, byte[] body, boolean durable, Long ttl, Long expiration, Integer priority, org.apache.activemq.artemis.api.core.client.ClientSession session)
protected String	generateDupId()
String	getDestination()
protected PostMessage.Pooled	getPooled()
int	getPoolSize()
long	getProducerTimeToLive()
DestinationServiceManager	getServiceManager()
org.apache.activemq.artemis.api.core.client.ClientSessionFactory	getSessionFactory()
void	init()
boolean	isDefaultDurable()
javax.ws.rs.core.Response	postWithId(String dupId, Boolean durable, Long ttl, Long expiration, Integer priority, javax.ws.rs.core.HttpHeaders headers, javax.ws.rs.core.UriInfo uriInfo, byte[] body)
void	publish(javax.ws.rs.core.HttpHeaders headers, byte[] body, String dup, boolean durable, Long ttl, Long expiration, Integer priority)
javax.ws.rs.core.Response	putWithId(String dupId, Boolean durable, Long ttl, Long expiration, Integer priority, javax.ws.rs.core.HttpHeaders headers, javax.ws.rs.core.UriInfo uriInfo, byte[] body)
void	setDefaultDurable(boolean defaultDurable)
void	setDestination(String destination)
void	setPoolSize(int poolSize)
void	setProducerTimeToLive(long producerTimeToLive)
void	setServiceManager(DestinationServiceManager serviceManager)
void	setSessionFactory(org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory)

Methods inherited from class java.lang.Object

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

Field Detail

sessionFactory

protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory

destination

protected String destination

defaultDurable

protected boolean defaultDurable

serviceManager

protected DestinationServiceManager serviceManager

producerTimeToLive

protected long producerTimeToLive

pool

protected ArrayBlockingQueue<PostMessage.Pooled> pool

poolSize

protected int poolSize

Constructor Detail

PostMessage

public PostMessage()

Method Detail

generateDupId

protected String generateDupId()

publish

public void publish(javax.ws.rs.core.HttpHeaders headers,
                    byte[] body,
                    String dup,
                    boolean durable,
                    Long ttl,
                    Long expiration,
                    Integer priority)
             throws Exception

Throws:

Exception

putWithId

@PUT
 @Path(value="{id}")
public javax.ws.rs.core.Response putWithId(@PathParam(value="id")
                                                                     String dupId,
                                                                     @QueryParam(value="durable")
                                                                     Boolean durable,
                                                                     @QueryParam(value="ttl")
                                                                     Long ttl,
                                                                     @QueryParam(value="expiration")
                                                                     Long expiration,
                                                                     @QueryParam(value="priority")
                                                                     Integer priority,
                                                                     @Context
                                                                     javax.ws.rs.core.HttpHeaders headers,
                                                                     @Context
                                                                     javax.ws.rs.core.UriInfo uriInfo,
                                                                     byte[] body)

postWithId

@POST
 @Path(value="{id}")
public javax.ws.rs.core.Response postWithId(@PathParam(value="id")
                                                                       String dupId,
                                                                       @QueryParam(value="durable")
                                                                       Boolean durable,
                                                                       @QueryParam(value="ttl")
                                                                       Long ttl,
                                                                       @QueryParam(value="expiration")
                                                                       Long expiration,
                                                                       @QueryParam(value="priority")
                                                                       Integer priority,
                                                                       @Context
                                                                       javax.ws.rs.core.HttpHeaders headers,
                                                                       @Context
                                                                       javax.ws.rs.core.UriInfo uriInfo,
                                                                       byte[] body)

getProducerTimeToLive

public long getProducerTimeToLive()

setProducerTimeToLive

public void setProducerTimeToLive(long producerTimeToLive)

getServiceManager

public DestinationServiceManager getServiceManager()

setServiceManager

public void setServiceManager(DestinationServiceManager serviceManager)

getSessionFactory

public org.apache.activemq.artemis.api.core.client.ClientSessionFactory getSessionFactory()

setSessionFactory

public void setSessionFactory(org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory)

getDestination

public String getDestination()

setDestination

public void setDestination(String destination)

isDefaultDurable

public boolean isDefaultDurable()

setDefaultDurable

public void setDefaultDurable(boolean defaultDurable)

getPoolSize

public int getPoolSize()

setPoolSize

public void setPoolSize(int poolSize)

init

public void init()
          throws Exception

Throws:

Exception

addPooled

protected void addPooled()
                  throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

getPooled

protected PostMessage.Pooled getPooled()
                                throws InterruptedException

Throws:

InterruptedException

cleanup

public void cleanup()

createActiveMQMessage

protected org.apache.activemq.artemis.api.core.client.ClientMessage createActiveMQMessage(javax.ws.rs.core.HttpHeaders headers,
                                                                                          byte[] body,
                                                                                          boolean durable,
                                                                                          Long ttl,
                                                                                          Long expiration,
                                                                                          Integer priority,
                                                                                          org.apache.activemq.artemis.api.core.client.ClientSession session)
                                                                                   throws Exception

Throws:

Exception