org.apache.camel.pojo
Class PojoEndpoint

java.lang.Object
  extended by org.apache.camel.impl.DefaultEndpoint<PojoExchange>
      extended by org.apache.camel.pojo.PojoEndpoint
All Implemented Interfaces:
Endpoint<PojoExchange>, Processor<PojoExchange>

public class PojoEndpoint
extends DefaultEndpoint<PojoExchange>

Represents a pojo endpoint that uses reflection to send messages around.

Version:
$Revision: 519973 $

Field Summary
 
Fields inherited from class org.apache.camel.impl.DefaultEndpoint
activated, deactivated
 
Constructor Summary
PojoEndpoint(String uri, CamelContext container, PojoComponent component, Object pojo)
           
 
Method Summary
 PojoExchange createExchange()
          Create a new exchange for communicating with this endpoint
 Object createInboundProxy(Class[] interfaces)
          Creates a Proxy object that can be used to deliver inbound PojoExchanges.
protected  void doActivate()
          Called at most once by the container to activate the endpoint
protected  void doDeactivate()
          Called at most once by the container to deactivate the endpoint
 void onExchange(PojoExchange exchange)
          This causes us to invoke the endpoint Pojo using reflection.
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
activate, convertTo, createExchange, deactivate, equals, getContext, getEndpointUri, getInboundProcessor, hashCode, setInboundProcessor, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

PojoEndpoint

public PojoEndpoint(String uri,
                    CamelContext container,
                    PojoComponent component,
                    Object pojo)
Method Detail

onExchange

public void onExchange(PojoExchange exchange)
This causes us to invoke the endpoint Pojo using reflection.


createExchange

public PojoExchange createExchange()
Description copied from interface: Endpoint
Create a new exchange for communicating with this endpoint


doActivate

protected void doActivate()
Description copied from class: DefaultEndpoint
Called at most once by the container to activate the endpoint

Overrides:
doActivate in class DefaultEndpoint<PojoExchange>

doDeactivate

protected void doDeactivate()
Description copied from class: DefaultEndpoint
Called at most once by the container to deactivate the endpoint

Overrides:
doDeactivate in class DefaultEndpoint<PojoExchange>

createInboundProxy

public Object createInboundProxy(Class[] interfaces)
Creates a Proxy object that can be used to deliver inbound PojoExchanges.

Parameters:
interfaces -
Returns:


Copyright © 2007 Apache Software Foundation. All Rights Reserved.