Java Doc for DeliveryChannelImpl.java in  » ESB » open-esb » com » sun » jbi » messaging » 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 » open esb » com.sun.jbi.messaging   Source Cross Reference   Class Diagram   Java Document (Java Doc)   java.lang.Object    com.sun.jbi.messaging.DeliveryChannelImpl DeliveryChannelImpl public class DeliveryChannelImpl implements DeliveryChannel,ChannelStatistics(Code) Implementation of DeliveryChannel interface. author:    Sun Microsystems, Inc. Field Summary final public static  String REG_NOTIFICATION_TYPE      Constructor Summary   DeliveryChannelImpl(String channelId, ClassLoader classLoader, MessageService msgSvc, EndpointListener listener)      Create a new DeliveryChannel. Method Summary public  MessageExchange accept()      Blocking call which samples the channel at a pre-determined interval for available exchanges. public  MessageExchange accept(long timeout)      public  RegisteredEndpoint activateEndpoint(QName service, String endpoint)      Activate an endpoint. public synchronized  boolean activeReference(MessageExchange me)      Check if a MessageExchange is being tracked. synchronized  void addAcceptReference(MessageExchangeProxy me)      synchronized  void addSendReference(MessageExchangeProxy me)      Track the given MessageExchange. synchronized  void addSendSyncReference(MessageExchangeProxy me)      Track the given MessageExchange.  void cleanActive()      Clean up in preparation for closing the channel. public  void close()      Close the channel. public  ServiceEndpoint createEndpoint(QName service, String endpoint)      public  MessageExchange createExchange(URI pattern, String id)      public  MessageExchangeFactory createExchangeFactory()      Create a message exchange factory. public  MessageExchangeFactory createExchangeFactory(QName interfaceName)      Create a message exchange factory for the given interface name. public  MessageExchangeFactory createExchangeFactory(ServiceEndpoint endpoint)      Create a message exchange factory for the given endpoint. public  MessageExchangeFactory createExchangeFactoryForService(QName serviceName)      Create a message exchange factory for the given service name. public  void deactivateEndpoint(ServiceEndpoint ref)      Used by a BC to deactivate an endpoint which it has registered. synchronized  MessageExchangeProxy dequeueExchange()      Dequeue a message exchange. synchronized  MessageExchangeProxy dequeueExchange(long timeout)      Dequeue a message exchange. public  void deregisterExternalEndpoint(ServiceEndpoint externalEndpoint)      Deregisters the specified external endpoint with the NMR.  DeliveryChannelImpl getChannel(String id)      Helper the forward channel lookup to MessageService.  String getChannelId()      Retrieve the id for this channel. public  ClassLoader getClassLoader()      synchronized  RegisteredEndpoint getConsumingEndpointByExternalName(String name)      public  String[] getConsumingEndpointNames()      public  ServiceEndpoint getEndpoint(QName service, String name)      Get the service description for the named endpoint, if any exists. synchronized  RegisteredEndpoint getEndpointByExternalName(String name)      public  Document getEndpointDescriptor(ServiceEndpoint endpoint)      Uses the owner id of the reference to query the appopriate channel. public  String[] getEndpointNames()      public  EndpointStatistics getEndpointStatistics(String name)      public  ServiceEndpoint[] getEndpoints(QName interfaceName)      Queries the NMR for active endpoints that implement the given interface. This will return the endpoints for all services and endpoints that implement the named interface (portType in WSDL 1.1). public  ServiceEndpoint[] getEndpoints()      public  ServiceEndpoint[] getEndpointsForService(QName service)      Used by ComponentContext.getEndpointsForService(). public  ServiceEndpoint[] getExternalEndpoints(QName interfaceName)      Queries the NMR for external endpoints that implement the specified interface name. public  ServiceEndpoint[] getExternalEndpointsForService(QName serviceName)      Queries the NMR for external endpoints that are part of the specified service. public  String getName()      public  CompositeData getStatistics()      public  boolean isClosed()      public  boolean isExchangeOkay(MessageExchange me)      final public  boolean isTransactional()       void propagateStatistics(MessageExchangeProxy me)      synchronized  void queueExchange(MessageExchangeProxy mep)      Queue a message exchange. synchronized  void queueObserved(MessageExchangeProxy mep)      public  void registerExternalEndpoint(ServiceEndpoint externalEndpoint)      Registers the specified external endpoint with the NMR. public  void registerXAResource(XAResource resource)      synchronized  void removeAcceptReference(MessageExchangeProxy me)      Stop tracking the given MessageExchange. synchronized  void removeSendReference(MessageExchangeProxy me)      Stop tracking the given MessageExchange. public  ServiceEndpoint resolveEndpointReference(org.w3c.dom.DocumentFragment endpointReference)      Resolves the specified endpoint reference into a service endpoint. public  void send(MessageExchange exchange)      Defers routing to the message service. public  boolean sendSync(MessageExchange exchange)      public  boolean sendSync(MessageExchange exchange, long timeout)      public  void setEndpointListener(EndpointListener listener)      public  void setExchangeIdGenerator(ExchangeIdGenerator generator)      public  void setTimeoutListener(TimeoutListener timeout)      public  void setTransactional(boolean transactional)      public  String toString()      synchronized  void updateConsumerStatistics(METimestamps ts)      synchronized  void updateProviderStatistics(METimestamps ts)      synchronized  void updateStatistics(MessageExchangeProxy me)      Field Detail REG_NOTIFICATION_TYPE final public static String REG_NOTIFICATION_TYPE(Code) Constructor Detail DeliveryChannelImpl DeliveryChannelImpl(String channelId, ClassLoader classLoader, MessageService msgSvc, EndpointListener listener)(Code) Create a new DeliveryChannel. Parameters:   channelId - component id Parameters:   msgSvc - message service Method Detail accept public MessageExchange accept() throws javax.jbi.messaging.MessagingException(Code) Blocking call which samples the channel at a pre-determined interval for available exchanges. message exchange, or null if channel was interrupted. throws:   javax.jbi.messaging.MessagingException - error while readingexchange. accept public MessageExchange accept(long timeout) throws javax.jbi.messaging.MessagingException(Code) activateEndpoint public RegisteredEndpoint activateEndpoint(QName service, String endpoint) throws javax.jbi.messaging.MessagingException(Code) Activate an endpoint. Parameters:   service - QName of service Parameters:   endpoint - NCName of endpoint activated endpoint throws:   javax.jbi.messaging.MessagingException - failed to register endpoint activeReference public synchronized boolean activeReference(MessageExchange me)(Code) Check if a MessageExchange is being tracked. addAcceptReference synchronized void addAcceptReference(MessageExchangeProxy me)(Code) addSendReference synchronized void addSendReference(MessageExchangeProxy me)(Code) Track the given MessageExchange. addSendSyncReference synchronized void addSendSyncReference(MessageExchangeProxy me)(Code) Track the given MessageExchange. cleanActive void cleanActive()(Code) Clean up in preparation for closing the channel. close public void close() throws javax.jbi.messaging.MessagingException(Code) Close the channel. throws:   javax.jbi.messaging.MessagingException - failure during close. createEndpoint public ServiceEndpoint createEndpoint(QName service, String endpoint) throws javax.jbi.messaging.MessagingException(Code) createExchange public MessageExchange createExchange(URI pattern, String id) throws javax.jbi.messaging.MessagingException(Code) createExchangeFactory public MessageExchangeFactory createExchangeFactory()(Code) Create a message exchange factory. This factory will create exchange instances with all appropriate properties set to null. a message exchange factory createExchangeFactory public MessageExchangeFactory createExchangeFactory(QName interfaceName)(Code) Create a message exchange factory for the given interface name. Parameters:   interfaceName - name of the interface for which all exchanges created by the returned factory will be set name of the interface for which all exchanges created by the returned factory will be set createExchangeFactory public MessageExchangeFactory createExchangeFactory(ServiceEndpoint endpoint)(Code) Create a message exchange factory for the given endpoint. Parameters:   endpoint - endpoint for which all exchanges created by thereturned factory will be set for an exchange factory that will create exchanges for the given endpoint createExchangeFactoryForService public MessageExchangeFactory createExchangeFactoryForService(QName serviceName)(Code) Create a message exchange factory for the given service name. Parameters:   serviceName - name of the service for which all exchanges created by the returned factory will be set an exchange factory that will create exchanges for the given service; must be non-null deactivateEndpoint public void deactivateEndpoint(ServiceEndpoint ref) throws javax.jbi.messaging.MessagingException(Code) Used by a BC to deactivate an endpoint which it has registered. Parameters:   ref - endpoint reference throws:   javax.jbi.messaging.MessagingException - failed to deactivate endpoint. dequeueExchange synchronized MessageExchangeProxy dequeueExchange() throws javax.jbi.messaging.MessagingException(Code) Dequeue a message exchange. Wait if the queue is empty. dequeueExchange synchronized MessageExchangeProxy dequeueExchange(long timeout) throws javax.jbi.messaging.MessagingException(Code) Dequeue a message exchange. Wait for the given number of milliseconds if the queue is empty. deregisterExternalEndpoint public void deregisterExternalEndpoint(ServiceEndpoint externalEndpoint) throws javax.jbi.messaging.MessagingException(Code) Deregisters the specified external endpoint with the NMR. This indicates to the NMR that external service consumers can no longer access the internal service by this name. getChannel DeliveryChannelImpl getChannel(String id)(Code) Helper the forward channel lookup to MessageService. getChannelId String getChannelId()(Code) Retrieve the id for this channel. getClassLoader public ClassLoader getClassLoader()(Code) getConsumingEndpointByExternalName synchronized RegisteredEndpoint getConsumingEndpointByExternalName(String name)(Code) getConsumingEndpointNames public String[] getConsumingEndpointNames()(Code) getEndpoint public ServiceEndpoint getEndpoint(QName service, String name)(Code) Get the service description for the named endpoint, if any exists. Parameters:   service - the qualified name of the endpoint's service. getEndpointByExternalName synchronized RegisteredEndpoint getEndpointByExternalName(String name)(Code) getEndpointDescriptor public Document getEndpointDescriptor(ServiceEndpoint endpoint) throws javax.jbi.messaging.MessagingException(Code) Uses the owner id of the reference to query the appopriate channel. getEndpointNames public String[] getEndpointNames()(Code) getEndpointStatistics public EndpointStatistics getEndpointStatistics(String name)(Code) getEndpoints public ServiceEndpoint[] getEndpoints(QName interfaceName)(Code) Queries the NMR for active endpoints that implement the given interface. This will return the endpoints for all services and endpoints that implement the named interface (portType in WSDL 1.1). This method does NOT include external endpoints (those registered using registerExternalEndpoint(ServiceEndpoint)). Parameters:   interfaceName - qualified name of interface/portType that is implemented by the endpoint ServiceEndpoint[] list of available endpoints for the specified interface name; potentially zero-length. getEndpoints public ServiceEndpoint[] getEndpoints()(Code) getEndpointsForService public ServiceEndpoint[] getEndpointsForService(QName service)(Code) Used by ComponentContext.getEndpointsForService(). getExternalEndpoints public ServiceEndpoint[] getExternalEndpoints(QName interfaceName)(Code) Queries the NMR for external endpoints that implement the specified interface name. getExternalEndpointsForService public ServiceEndpoint[] getExternalEndpointsForService(QName serviceName)(Code) Queries the NMR for external endpoints that are part of the specified service. getName public String getName()(Code) getStatistics public CompositeData getStatistics()(Code) isClosed public boolean isClosed()(Code) isExchangeOkay public boolean isExchangeOkay(MessageExchange me)(Code) isTransactional final public boolean isTransactional()(Code) propagateStatistics void propagateStatistics(MessageExchangeProxy me)(Code) queueExchange synchronized void queueExchange(MessageExchangeProxy mep) throws javax.jbi.messaging.MessagingException(Code) Queue a message exchange. Notify any waiters on 0->1 transition. queueObserved synchronized void queueObserved(MessageExchangeProxy mep) throws javax.jbi.messaging.MessagingException(Code) Queue a message exchange for an observer registerExternalEndpoint public void registerExternalEndpoint(ServiceEndpoint externalEndpoint) throws javax.jbi.messaging.MessagingException(Code) Registers the specified external endpoint with the NMR. This indicates to the NMR that the specified endpoint is used as a proxy for external service consumers to access an internal service by the same name. registerXAResource public void registerXAResource(XAResource resource)(Code) Register an XAResource Parameters:   resource - to be added. removeAcceptReference synchronized void removeAcceptReference(MessageExchangeProxy me)(Code) Stop tracking the given MessageExchange. removeSendReference synchronized void removeSendReference(MessageExchangeProxy me)(Code) Stop tracking the given MessageExchange. resolveEndpointReference public ServiceEndpoint resolveEndpointReference(org.w3c.dom.DocumentFragment endpointReference)(Code) Resolves the specified endpoint reference into a service endpoint. This is called by the component when it has an endpoint reference that it needs to resolve into a service endpoint. send public void send(MessageExchange exchange) throws javax.jbi.messaging.MessagingException(Code) Defers routing to the message service. sendSync public boolean sendSync(MessageExchange exchange) throws javax.jbi.messaging.MessagingException(Code) sendSync public boolean sendSync(MessageExchange exchange, long timeout) throws javax.jbi.messaging.MessagingException(Code) setEndpointListener public void setEndpointListener(EndpointListener listener)(Code) setExchangeIdGenerator public void setExchangeIdGenerator(ExchangeIdGenerator generator)(Code) setTimeoutListener public void setTimeoutListener(TimeoutListener timeout)(Code) setTransactional public void setTransactional(boolean transactional)(Code) toString public String toString()(Code) updateConsumerStatistics synchronized void updateConsumerStatistics(METimestamps ts)(Code) updateProviderStatistics synchronized void updateProviderStatistics(METimestamps ts)(Code) updateStatistics synchronized void updateStatistics(MessageExchangeProxy me)(Code) Methods inherited from java.lang.Object native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc) public boolean equals(Object obj)(Code)(Java Doc) protected void finalize() throws Throwable(Code)(Java Doc) final native public Class getClass()(Code)(Java Doc) native public int hashCode()(Code)(Java Doc) final native public void notify()(Code)(Java Doc) final native public void notifyAll()(Code)(Java Doc) public String toString()(Code)(Java Doc) final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc) final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc) final public void wait() throws InterruptedException(Code)(Java Doc)