com.si.celery.connection

Class AMQPConnectionFactory

java.lang.Object

com.si.celery.connection.AMQPConnectionFactory

All Implemented Interfaces:

ConnectionBuilder

public class AMQPConnectionFactory
extends java.lang.Object
implements ConnectionBuilder

Basic Connection using AMQP

Constructor Summary

Constructors

Constructor and Description
AMQPConnectionFactory() Constructor

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.Connection	build() Build the AMQP Connection
ConnectionBuilder	setClientProperties(java.util.Map<java.lang.String,java.lang.Object> properties) Set the client properties
ConnectionBuilder	setHost(java.lang.String host) Set the host
ConnectionBuilder	setPassword(java.lang.String password) Set the password
ConnectionBuilder	setPort(int port) Set the port
ConnectionBuilder	setURI(java.lang.String uri) Set the entire URI at once
ConnectionBuilder	setUsername(java.lang.String username) The username
ConnectionBuilder	setVirtualHost(java.lang.String virtualHost) Set the virtual host
ConnectionBuilder	useSSLProtocol() Use the SSL protocol

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPConnectionFactory

public AMQPConnectionFactory()

Constructor

Method Detail

setHost

public ConnectionBuilder setHost(java.lang.String host)

Set the host

Specified by:

setHost in interface ConnectionBuilder

Parameters:

host - The host string

Returns:

this AMQPConnectionFactory

setPort

public ConnectionBuilder setPort(int port)

Set the port

Specified by:

setPort in interface ConnectionBuilder

Parameters:

port - The port int

Returns:

This AMQPConnectionFactory

setPassword

public ConnectionBuilder setPassword(java.lang.String password)

Set the password

Specified by:

setPassword in interface ConnectionBuilder

Parameters:

password - The password string

Returns:

This AMQPConnectionFactory

setUsername

public ConnectionBuilder setUsername(java.lang.String username)

The username

Specified by:

setUsername in interface ConnectionBuilder

Parameters:

username - The username string

Returns:

This AMQPConnectionFactory

setClientProperties

public ConnectionBuilder setClientProperties(java.util.Map<java.lang.String,java.lang.Object> properties)

Set the client properties

Specified by:

setClientProperties in interface ConnectionBuilder

Parameters:

properties - The client properties

Returns:

this AMQPConnectionFactory

setVirtualHost

public ConnectionBuilder setVirtualHost(java.lang.String virtualHost)

Set the virtual host

Specified by:

setVirtualHost in interface ConnectionBuilder

Parameters:

virtualHost - The virtual host string

Returns:

This AMQPConnectionFactory

useSSLProtocol

public ConnectionBuilder useSSLProtocol()
                                 throws java.security.NoSuchAlgorithmException,
                                        java.security.KeyManagementException

Use the SSL protocol

Specified by:

useSSLProtocol in interface ConnectionBuilder

Returns:

This AMQPConnectionFactory

Throws:

java.security.NoSuchAlgorithmException

java.security.KeyManagementException

setURI

public ConnectionBuilder setURI(java.lang.String uri)
                         throws java.net.URISyntaxException,
                                java.security.NoSuchAlgorithmException,
                                java.security.KeyManagementException

Set the entire URI at once

Specified by:

setURI in interface ConnectionBuilder

Parameters:

uri - The uri

Returns:

This AMQPConnectionFactory

Throws:

java.net.URISyntaxException

java.security.NoSuchAlgorithmException

java.security.KeyManagementException

build

public com.rabbitmq.client.Connection build()
                                     throws java.io.IOException,
                                            java.util.concurrent.TimeoutException

Build the AMQP Connection

Specified by:

build in interface ConnectionBuilder

Returns:

An AMQP connection

Throws:

java.io.IOException

java.util.concurrent.TimeoutException