org.apache.camel.component.openshift

Class OpenShiftEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.apache.camel.impl.ScheduledPollEndpoint

org.apache.camel.component.openshift.OpenShiftEndpoint

All Implemented Interfaces:

CamelContextAware, Endpoint, IsSingleton, Service, ShutdownableService, HasId, StatefulService, SuspendableService

@UriEndpoint(scheme="openshift",
             title="OpenShift",
             syntax="openshift:clientId",
             consumerClass=OpenShiftConsumer.class,
             label="cloud,paas")
public class OpenShiftEndpoint
extends ScheduledPollEndpoint

To manage your Openshift 2.x applications.

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
OpenShiftEndpoint(String endpointUri, Component component)

Method Summary

Modifier and Type	Method and Description
Consumer	createConsumer(Processor processor) Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
Exchange	createExchange(com.openshift.client.IApplication application)
Producer	createProducer() Creates a new producer which is used send messages into the endpoint
String	getApplication()
String	getClientId()
String	getDomain()
String	getMode()
String	getOperation()
String	getPassword()
String	getServer()
String	getUsername()
boolean	isSingleton() Whether this class supports being singleton or not.
void	setApplication(String application) The application name to start, stop, restart, or get the state.
void	setClientId(String clientId) The client id
void	setDomain(String domain) Domain name.
void	setMode(String mode) Whether to output the message body as a pojo or json.
void	setOperation(OpenShiftOperation operation)
void	setOperation(String operation) The operation to perform which can be: list, start, stop, restart, and state.
void	setPassword(String password) The password for login to openshift server.
void	setServer(String server) Url to the openshift server.
void	setUsername(String username) The username to login to openshift server.

Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint

configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

OpenShiftEndpoint

public OpenShiftEndpoint(String endpointUri,
                         Component component)

Method Detail

createProducer

public Producer createProducer()
                        throws Exception

Description copied from interface: Endpoint

Creates a new producer which is used send messages into the endpoint

Returns:

a newly created producer

Throws:

Exception - can be thrown

createConsumer

public Consumer createConsumer(Processor processor)
                        throws Exception

Description copied from interface: Endpoint

Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor

Parameters:

processor - the given processor

Returns:

a newly created consumer

Throws:

Exception - can be thrown

createExchange

public Exchange createExchange(com.openshift.client.IApplication application)

isSingleton

public boolean isSingleton()

Description copied from interface: IsSingleton

Whether this class supports being singleton or not.

Returns:

true to be a single shared instance, false to create new instances.

getUsername

public String getUsername()

setUsername

public void setUsername(String username)

The username to login to openshift server.

getPassword

public String getPassword()

setPassword

public void setPassword(String password)

The password for login to openshift server.

getClientId

public String getClientId()

setClientId

public void setClientId(String clientId)

The client id

getDomain

public String getDomain()

setDomain

public void setDomain(String domain)

Domain name. If not specified then the default domain is used.

getServer

public String getServer()

setServer

public void setServer(String server)

Url to the openshift server. If not specified then the default value from the local openshift configuration file ~/.openshift/express.conf is used. And if that fails as well then "openshift.redhat.com" is used.

getOperation

public String getOperation()

setOperation

public void setOperation(String operation)

The operation to perform which can be: list, start, stop, restart, and state. The list operation returns information about all the applications in json format. The state operation returns the state such as: started, stopped etc. The other operations does not return any value.

setOperation

public void setOperation(OpenShiftOperation operation)

getApplication

public String getApplication()

setApplication

public void setApplication(String application)

The application name to start, stop, restart, or get the state.

getMode

public String getMode()

setMode

public void setMode(String mode)

Whether to output the message body as a pojo or json. For pojo the message is a List type.