org.apache.activemq.artemis.rest.queue.push

Class UriStrategy

java.lang.Object

org.apache.activemq.artemis.rest.queue.push.UriStrategy

All Implemented Interfaces:

PushStrategy

Direct Known Subclasses:

UriTemplateStrategy

public class UriStrategy
extends Object
implements PushStrategy

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.http.client.HttpClient	client
protected String	contentType
protected org.jboss.resteasy.client.core.executors.ApacheHttpClient4Executor	executor
protected ConnectionFactoryOptions	jmsOptions
protected org.apache.http.protocol.BasicHttpContext	localContext
protected String	method
protected PushRegistration	registration
protected javax.ws.rs.core.UriBuilder	targetUri

Method Summary

Modifier and Type	Method and Description
protected String	createUri(ClientMessage message)
protected void	initAuthentication()
boolean	push(ClientMessage message) Return false if unable to connect.
void	setJmsOptions(ConnectionFactoryOptions jmsOptions)
void	setRegistration(PushRegistration reg)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

client

protected org.apache.http.client.HttpClient client

localContext

protected org.apache.http.protocol.BasicHttpContext localContext

executor

protected org.jboss.resteasy.client.core.executors.ApacheHttpClient4Executor executor

registration

protected PushRegistration registration

targetUri

protected javax.ws.rs.core.UriBuilder targetUri

method

protected String method

contentType

protected String contentType

jmsOptions

protected ConnectionFactoryOptions jmsOptions

Method Detail

setRegistration

public void setRegistration(PushRegistration reg)

Specified by:

setRegistration in interface PushStrategy

start

public void start()
           throws Exception

Specified by:

start in interface PushStrategy

Throws:

Exception

initAuthentication

protected void initAuthentication()

stop

public void stop()

Specified by:

stop in interface PushStrategy

setJmsOptions

public void setJmsOptions(ConnectionFactoryOptions jmsOptions)

Specified by:

setJmsOptions in interface PushStrategy

push

public boolean push(ClientMessage message)

Description copied from interface: PushStrategy

Return false if unable to connect. Push consumer may be disabled if configured to do so when unable to connect. Throw an exception if the message sent was unaccepted by the receiver. ActiveMQ's retry and dead letter logic will take over from there.

Specified by:

push in interface PushStrategy

Returns:

false if unable to connect

createUri

protected String createUri(ClientMessage message)