com.si.celery.broker

Interface Broker

All Known Implementing Classes:

RabbitMQBroker

public interface Broker

Broker interface

Method Summary

Modifier and Type	Method and Description
void	connect()
SubtaskRunner	sendTask(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs)
SubtaskRunner	sendTask(java.lang.String taskName, java.lang.Object[] args, java.util.Map<java.lang.String,java.lang.Object> kwargs, java.lang.String replyTo, java.lang.String correlationId, java.util.Date expires, int priority, java.lang.Long timeLimit, java.lang.Long softTimeLimit, java.util.Date eta, int retries)
void	setOrigin(java.lang.String origin)

Method Detail

setOrigin

void setOrigin(java.lang.String origin)

connect

void connect()
      throws BrokerConnectionException

Throws:

BrokerConnectionException

sendTask

SubtaskRunner sendTask(java.lang.String taskName,
                       java.lang.Object[] args,
                       java.util.Map<java.lang.String,java.lang.Object> kwargs,
                       java.lang.String replyTo,
                       java.lang.String correlationId,
                       java.util.Date expires,
                       int priority,
                       java.lang.Long timeLimit,
                       java.lang.Long softTimeLimit,
                       java.util.Date eta,
                       int retries)
                throws BrokerSendTaskException

Throws:

BrokerSendTaskException

sendTask

SubtaskRunner sendTask(java.lang.String taskName,
                       java.lang.Object[] args,
                       java.util.Map<java.lang.String,java.lang.Object> kwargs)
                throws BrokerSendTaskException

Throws:

BrokerSendTaskException