org.hornetq.rest.queue.push

Class HornetQPushStrategy

java.lang.Object

org.hornetq.rest.queue.push.UriStrategy

org.hornetq.rest.queue.push.UriTemplateStrategy

org.hornetq.rest.queue.push.HornetQPushStrategy

All Implemented Interfaces:

PushStrategy

public class HornetQPushStrategy
extends UriTemplateStrategy

Forwarding to a HornetQ/REST-* endpoing

Version:

$Revision: 1 $

Author:

Bill Burke

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	initialized

Fields inherited from class org.hornetq.rest.queue.push.UriStrategy

client, contentType, executor, localContext, method, registration, targetUri

Constructor Summary

Constructors

Constructor and Description
HornetQPushStrategy()

Method Summary

Modifier and Type	Method and Description
protected void	initialize()
boolean	push(ClientMessage message) Return false if unable to connect.
void	start()

Methods inherited from class org.hornetq.rest.queue.push.UriTemplateStrategy

createUri

Methods inherited from class org.hornetq.rest.queue.push.UriStrategy

initAuthentication, setRegistration, stop

Methods inherited from class java.lang.Object

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

Field Detail

initialized

protected boolean initialized

Constructor Detail

HornetQPushStrategy

public HornetQPushStrategy()

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface PushStrategy

Overrides:

start in class UriStrategy

Throws:

Exception

initialize

protected void initialize()
                   throws Exception

Throws:

Exception

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. Hornetq's retry and dead letter logic will take over from there.

Specified by:

push in interface PushStrategy

Overrides:

push in class UriStrategy

Returns:

false if unable to connect