Java Doc for AbstractConsumerEndpoint.java in  » ESB » servicemix » org » apache » servicemix » jms » endpoints » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation
1. 6.0 JDK Core
2. 6.0 JDK Modules
3. 6.0 JDK Modules com.sun
4. 6.0 JDK Modules com.sun.java
5. 6.0 JDK Modules sun
6. 6.0 JDK Platform
7. Ajax
8. Apache Harmony Java SE
9. Aspect oriented
10. Authentication Authorization
11. Blogger System
12. Build
13. Byte Code
14. Cache
15. Chart
16. Chat
17. Code Analyzer
18. Collaboration
19. Content Management System
20. Database Client
21. Database DBMS
22. Database JDBC Connection Pool
23. Database ORM
24. Development
25. EJB Server geronimo
26. EJB Server GlassFish
27. EJB Server JBoss 4.2.1
28. EJB Server resin 3.1.5
29. ERP CRM Financial
30. ESB
31. Forum
32. GIS
33. Graphic Library
34. Groupware
35. HTML Parser
36. IDE
37. IDE Eclipse
38. IDE Netbeans
39. Installer
40. Internationalization Localization
41. Inversion of Control
42. Issue Tracking
43. J2EE
44. JBoss
45. JMS
46. JMX
47. Library
48. Mail Clients
49. Net
50. Parser
51. PDF
52. Portal
53. Profiler
54. Project Management
55. Report
56. RSS RDF
57. Rule Engine
58. Science
59. Scripting
60. Search Engine
61. Security
62. Sevlet Container
63. Source Control
64. Swing Library
65. Template Engine
66. Test Coverage
67. Testing
68. UML
69. Web Crawler
70. Web Framework
71. Web Mail
72. Web Server
73. Web Services
74. Web Services apache cxf 2.0.1
75. Web Services AXIS2
76. Wiki Engine
77. Workflow Engines
78. XML
79. XML UI
Java
Java Tutorial
Java Open Source
Jar File Download
Java Articles
Java Products
Java by API
Photoshop Tutorials
Maya Tutorials
Flash Tutorials
3ds-Max Tutorials
Illustrator Tutorials
GIMP Tutorials
C# / C Sharp
C# / CSharp Tutorial
C# / CSharp Open Source
ASP.Net
ASP.NET Tutorial
JavaScript DHTML
JavaScript Tutorial
JavaScript Reference
HTML / CSS
HTML CSS Reference
C / ANSI-C
C Tutorial
C++
C++ Tutorial
Ruby
PHP
Python
Python Tutorial
Python Open Source
SQL Server / T-SQL
SQL Server / T-SQL Tutorial
Oracle PL / SQL
Oracle PL/SQL Tutorial
PostgreSQL
SQL / MySQL
MySQL Tutorial
VB.Net
VB.Net Tutorial
Flash / Flex / ActionScript
VBA / Excel / Access / Word
XML
XML Tutorial
Microsoft Office PowerPoint 2007 Tutorial
Microsoft Office Excel 2007 Tutorial
Microsoft Office Word 2007 Tutorial
Java Source Code / Java Documentation » ESB » servicemix » org.apache.servicemix.jms.endpoints 
Source Cross Reference  Class Diagram Java Document (Java Doc) 


org.apache.servicemix.common.endpoints.ConsumerEndpoint
   org.apache.servicemix.jms.endpoints.AbstractConsumerEndpoint

All known Subclasses:   org.apache.servicemix.jms.endpoints.JmsConsumerEndpoint,  org.apache.servicemix.jms.endpoints.JmsJcaConsumerEndpoint,
AbstractConsumerEndpoint
abstract public class AbstractConsumerEndpoint extends ConsumerEndpoint (Code)


Field Summary
final protected static  StringPROP_JMS_CONTEXT
    

Constructor Summary
public  AbstractConsumerEndpoint()
    
public  AbstractConsumerEndpoint(DefaultComponent component, ServiceEndpoint endpoint)
    
public  AbstractConsumerEndpoint(ServiceUnit serviceUnit, QName service, String endpoint)
    

Method Summary
public  ConnectionFactorygetConnectionFactory()
    
public  DestinationChoosergetDestinationChooser()
    
public  DestinationResolvergetDestinationResolver()
    
public  StringgetLocationURI()
    
public  JmsConsumerMarshalergetMarshaler()
    
public  intgetReplyDeliveryMode()
    
public  DestinationgetReplyDestination()
    
protected  DestinationgetReplyDestination(MessageExchange exchange, Object message, Session session, JmsContext context)
    
public  StringgetReplyDestinationName()
    
public  intgetReplyPriority()
    
public  Map<String, Object>getReplyProperties()
    
public  longgetReplyTimeToLive()
    
public  StoregetStore()
    
public  StoreFactorygetStoreFactory()
    
public  BooleangetUseMessageIdInResponse()
    
protected  voidhandleException(MessageExchange exchange, Exception error, Session session, JmsContext context)
    
public  booleanisPubSubDomain()
    
public  booleanisReplyExplicitQosEnabled()
    
public  booleanisStateless()
    
public  booleanisSynchronous()
    
protected  voidonMessage(Message jmsMessage, Session session)
    
public  voidprocess(MessageExchange exchange)
    
protected  voidprocessExchange(MessageExchange exchange, Session session, JmsContext context)
    
protected  voidsend(Message msg, Session session, Destination dest)
    
protected  voidsendError(MessageExchange exchange, Exception error, Session session, JmsContext context)
    
public  voidsetConnectionFactory(ConnectionFactory connectionFactory)
    
protected  voidsetCorrelationId(Message query, Message reply)
    
public  voidsetDestinationChooser(DestinationChooser destinationChooser)
    
public  voidsetDestinationResolver(DestinationResolver destinationResolver)
    
public  voidsetMarshaler(JmsConsumerMarshaler marshaler)
    
public  voidsetPubSubDomain(boolean pubSubDomain)
    
public  voidsetReplyDeliveryMode(int replyDeliveryMode)
    
public  voidsetReplyDestination(Destination replyDestination)
    
public  voidsetReplyDestinationName(String replyDestinationName)
    
public  voidsetReplyExplicitQosEnabled(boolean replyExplicitQosEnabled)
    
public  voidsetReplyPriority(int replyPriority)
    
public  voidsetReplyProperties(Map<String, Object> replyProperties)
    
public  voidsetReplyTimeToLive(long replyTimeToLive)
    
public  voidsetStateless(boolean stateless)
    
public  voidsetStore(Store store)
    
public  voidsetStoreFactory(StoreFactory storeFactory)
    
public  voidsetSynchronous(boolean synchronous)
    
public  voidsetUseMessageIdInResponse(Boolean useMessageIdInResponse)
    
public synchronized  voidstart()
    
public synchronized  voidstop()
    
protected  booleantreatExceptionAsFault(Exception error)
    

Field Detail
PROP_JMS_CONTEXT
final protected static String PROP_JMS_CONTEXT(Code)




Constructor Detail
AbstractConsumerEndpoint
public AbstractConsumerEndpoint()(Code)



AbstractConsumerEndpoint
public AbstractConsumerEndpoint(DefaultComponent component, ServiceEndpoint endpoint)(Code)



AbstractConsumerEndpoint
public AbstractConsumerEndpoint(ServiceUnit serviceUnit, QName service, String endpoint)(Code)




Method Detail
getConnectionFactory
public ConnectionFactory getConnectionFactory()(Code)
the connectionFactory



getDestinationChooser
public DestinationChooser getDestinationChooser()(Code)
the destinationChooser



getDestinationResolver
public DestinationResolver getDestinationResolver()(Code)
the destinationResolver



getLocationURI
public String getLocationURI()(Code)



getMarshaler
public JmsConsumerMarshaler getMarshaler()(Code)
the marshaler



getReplyDeliveryMode
public int getReplyDeliveryMode()(Code)
the replyDeliveryMode



getReplyDestination
public Destination getReplyDestination()(Code)
the replyDestination



getReplyDestination
protected Destination getReplyDestination(MessageExchange exchange, Object message, Session session, JmsContext context) throws JMSException(Code)



getReplyDestinationName
public String getReplyDestinationName()(Code)
the replyDestinationName



getReplyPriority
public int getReplyPriority()(Code)
the replyPriority



getReplyProperties
public Map<String, Object> getReplyProperties()(Code)
the replyProperties



getReplyTimeToLive
public long getReplyTimeToLive()(Code)
the replyTimeToLive



getStore
public Store getStore()(Code)



getStoreFactory
public StoreFactory getStoreFactory()(Code)



getUseMessageIdInResponse
public Boolean getUseMessageIdInResponse()(Code)
the useMessageIdInResponse



handleException
protected void handleException(MessageExchange exchange, Exception error, Session session, JmsContext context) throws Exception(Code)



isPubSubDomain
public boolean isPubSubDomain()(Code)
the pubSubDomain



isReplyExplicitQosEnabled
public boolean isReplyExplicitQosEnabled()(Code)
the replyExplicitQosEnabled



isStateless
public boolean isStateless()(Code)



isSynchronous
public boolean isSynchronous()(Code)
the synchronous



onMessage
protected void onMessage(Message jmsMessage, Session session) throws JMSException(Code)



process
public void process(MessageExchange exchange) throws Exception(Code)



processExchange
protected void processExchange(MessageExchange exchange, Session session, JmsContext context) throws Exception(Code)



send
protected void send(Message msg, Session session, Destination dest) throws JMSException(Code)



sendError
protected void sendError(MessageExchange exchange, Exception error, Session session, JmsContext context) throws Exception(Code)



setConnectionFactory
public void setConnectionFactory(ConnectionFactory connectionFactory)(Code)

Parameters:
  connectionFactory - the connectionFactory to set



setCorrelationId
protected void setCorrelationId(Message query, Message reply) throws Exception(Code)



setDestinationChooser
public void setDestinationChooser(DestinationChooser destinationChooser)(Code)

Parameters:
  destinationChooser - the destinationChooser to set



setDestinationResolver
public void setDestinationResolver(DestinationResolver destinationResolver)(Code)

Parameters:
  destinationResolver - the destinationResolver to set



setMarshaler
public void setMarshaler(JmsConsumerMarshaler marshaler)(Code)

Parameters:
  marshaler - the marshaler to set



setPubSubDomain
public void setPubSubDomain(boolean pubSubDomain)(Code)

Parameters:
  pubSubDomain - the pubSubDomain to set



setReplyDeliveryMode
public void setReplyDeliveryMode(int replyDeliveryMode)(Code)

Parameters:
  replyDeliveryMode - the replyDeliveryMode to set



setReplyDestination
public void setReplyDestination(Destination replyDestination)(Code)

Parameters:
  replyDestination - the replyDestination to set



setReplyDestinationName
public void setReplyDestinationName(String replyDestinationName)(Code)

Parameters:
  replyDestinationName - the replyDestinationName to set



setReplyExplicitQosEnabled
public void setReplyExplicitQosEnabled(boolean replyExplicitQosEnabled)(Code)

Parameters:
  replyExplicitQosEnabled - the replyExplicitQosEnabled to set



setReplyPriority
public void setReplyPriority(int replyPriority)(Code)

Parameters:
  replyPriority - the replyPriority to set



setReplyProperties
public void setReplyProperties(Map<String, Object> replyProperties)(Code)

Parameters:
  replyProperties - the replyProperties to set



setReplyTimeToLive
public void setReplyTimeToLive(long replyTimeToLive)(Code)

Parameters:
  replyTimeToLive - the replyTimeToLive to set



setStateless
public void setStateless(boolean stateless)(Code)



setStore
public void setStore(Store store)(Code)



setStoreFactory
public void setStoreFactory(StoreFactory storeFactory)(Code)



setSynchronous
public void setSynchronous(boolean synchronous)(Code)

Parameters:
  synchronous - the synchronous to set



setUseMessageIdInResponse
public void setUseMessageIdInResponse(Boolean useMessageIdInResponse)(Code)

Parameters:
  useMessageIdInResponse - the useMessageIdInResponse to set



start
public synchronized void start() throws Exception(Code)



stop
public synchronized void stop() throws Exception(Code)



treatExceptionAsFault
protected boolean treatExceptionAsFault(Exception error)(Code)



Methods inherited from org.apache.servicemix.common.endpoints.ConsumerEndpoint
protected void configureExchangeTarget(MessageExchange exchange)(Code)(Java Doc)
abstract public String getLocationURI()(Code)(Java Doc)
public Role getRole()(Code)(Java Doc)
public String getTargetEndpoint()(Code)(Java Doc)
public QName getTargetInterface()(Code)(Java Doc)
public QName getTargetOperation()(Code)(Java Doc)
public QName getTargetService()(Code)(Java Doc)
public String getTargetUri()(Code)(Java Doc)
public void setTargetEndpoint(String targetEndpoint)(Code)(Java Doc)
public void setTargetInterface(QName targetInterface)(Code)(Java Doc)
public void setTargetOperation(QName targetOperation)(Code)(Java Doc)
public void setTargetService(QName targetService)(Code)(Java Doc)
public void setTargetUri(String targetUri)(Code)(Java Doc)
public synchronized void start() throws Exception(Code)(Java Doc)
public synchronized void stop() throws Exception(Code)(Java Doc)
public void validate() throws DeploymentException(Code)(Java Doc)

www.java2java.com | Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.