Java Doc for ClientOutboundSequence.java in  » 6.0-JDK-Modules-com.sun » wsit » com » sun » xml » ws » rm » jaxws » runtime » client » 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 » 6.0 JDK Modules com.sun » wsit » com.sun.xml.ws.rm.jaxws.runtime.client   Source Cross Reference   Class Diagram   Java Document (Java Doc)   com.sun.xml.ws.rm.jaxws.runtime.OutboundSequence    com.sun.xml.ws.rm.jaxws.runtime.client.ClientOutboundSequence ClientOutboundSequence public class ClientOutboundSequence extends OutboundSequence implements ClientSequence(Code) ClientOutboundSequence represents the set of all messages from a single BindingProvider instance. It includes methods that connect and disconnect to a remote RMDestination using a client for a WebService that uses CreateSequence and TerminateSequence as its request messages. Field Summary protected  ProtocolMessageSender protocolMessageSender      protected  int receiveBufferSize      Current value of receive buffer read from incoming SequenceAcknowledgement messages if RM Destination implements properietary Indigo Flow Control feature. Constructor Summary public   ClientOutboundSequence(SequenceConfig config)      Method Summary public synchronized  void acknowledge(int i)      Implementation of acknowledge defers discarding stored messages when the AcksTo endpoint is anonymous and the message is a two-way request. In this case, the actual work usually done by acknowledge() needs to wait until the response is received. public synchronized  void acknowledgeResponse(int i)      Acknowledges that a response to a two-way operation has been received. public  void connect(URI destination, URI acksTo, boolean twoWay)      Connects to remote RM Destination by sending request through the proxy stored in the port field. Parameters:   destination - Destination URI for RM Destination Parameters:   acksTo - reply to EPR for protocol responses. public  void disconnect()      Disconnect from the RMDestination by invoking TerminateSequence on the proxy stored in the port field. public  void disconnect(boolean keepAlive)      Disconnect from the RMDestination by invoking TerminateSequence on the proxy stored in the port field. public synchronized  void doMaintenanceTasks()      Handler periodically invoked by RMSource.MaintenanceThread. public  AcknowledgementListener getAcknowledgementListener()      Accessor for the AcknowledgementListener field. public  int getReceiveBufferSize()      Accessor for the receiveBufferSize field. public  JAXBElement<SecurityTokenReferenceType> getSecurityTokenReference()      public  SequenceConfig getSequenceConfig()      public  SequenceSettings getSequenceSettings()      Implementation of the getSequenceSettings method in com.sun.xml.ws.rm.api.client.ClientSequence. public  Service getService()      Accessor for the service field. public  int getTransferWindowSize()      Return the hoped-for limit to number of stored messages. protected synchronized  boolean isAckRequested()      Checks whether an ack should be requested. public  boolean isAnonymous()      Return value is determined by whether the destination endpoint is the anonymous URI. public synchronized  boolean isResendDue()      Checks whether a resend should happen. public  boolean isSecureReliableMessaging()      public  boolean isTransferWindowFull()      Returns true if TransferWindow is full. public  void registerProtocolMessageSender(ProtocolMessageSender pms)      public synchronized  void requestAck()      public  void resend(int messageNumber)      Causes the specified message number to be resent. public  void setAcknowledgementListener(AcknowledgementListener listener)      public  void setReceiveBufferSize(int receiveBufferSize)      Mutator for the receiveBufferSize field. public  void setSecureReliableMessaging(boolean secureReliableMessaging)      public  void setSecurityTokenReference(JAXBElement<SecurityTokenReferenceType> str)      public  void setService(Service service)      Sets the value of the service field. Field Detail protocolMessageSender protected ProtocolMessageSender protocolMessageSender(Code) The helper class used to send protocol messages CreateSequenceElement CreateSequenceResponseElement LastMessage AckRequestedElement receiveBufferSize protected int receiveBufferSize(Code) Current value of receive buffer read from incoming SequenceAcknowledgement messages if RM Destination implements properietary Indigo Flow Control feature. Constructor Detail ClientOutboundSequence public ClientOutboundSequence(SequenceConfig config)(Code) Method Detail acknowledge public synchronized void acknowledge(int i) throws InvalidMessageNumberException(Code) Implementation of acknowledge defers discarding stored messages when the AcksTo endpoint is anonymous and the message is a two-way request. In this case, the actual work usually done by acknowledge() needs to wait until the response is received. The RMClientPipe invokes acknowledgeResponse at that time. Parameters:   i - The index to acknowledge throws:   InvalidMessageNumberException - acknowledgeResponse public synchronized void acknowledgeResponse(int i) throws InvalidMessageNumberException(Code) Acknowledges that a response to a two-way operation has been received. See Javadoc for acknowledge Parameters:   i - The index to acknowledge throws:   InvalidMessageNumberException - connect public void connect(URI destination, URI acksTo, boolean twoWay) throws RMException(Code) Connects to remote RM Destination by sending request through the proxy stored in the port field. Parameters:   destination - Destination URI for RM Destination Parameters:   acksTo - reply to EPR for protocol responses. The null value indicatesuse of the WS-Addressing anonymous EPR throws:   RMException - wrapper for all exceptions thrown during execution of method. disconnect public void disconnect() throws RMException(Code) Disconnect from the RMDestination by invoking TerminateSequence on the proxy stored in the port field. State of sequence is set to inactive. throws:   RMException - wrapper for all exceptions thrown during execution of method. disconnect public void disconnect(boolean keepAlive) throws RMException(Code) Disconnect from the RMDestination by invoking TerminateSequence on the proxy stored in the port field. Parameters:   keepAlive - If true, state of sequence is kept inactive atate allowing the reuse of the sequence. throws:   RMException - wrapper for all exceptions thrown during execution of method. doMaintenanceTasks public synchronized void doMaintenanceTasks() throws RMException(Code) Handler periodically invoked by RMSource.MaintenanceThread. Has two duties: Resend incomplete messages. Send AckRequested message down the pipeline if Inactivity timeout is approaching. throws:   RMException - getAcknowledgementListener public AcknowledgementListener getAcknowledgementListener()(Code) Accessor for the AcknowledgementListener field. The AcknowledgementListener. getReceiveBufferSize public int getReceiveBufferSize()(Code) Accessor for the receiveBufferSize field. The value for the field. getSecurityTokenReference public JAXBElement<SecurityTokenReferenceType> getSecurityTokenReference()(Code) getSequenceConfig public SequenceConfig getSequenceConfig()(Code) Accessor for the sequenceConfig field The value of the field. getSequenceSettings public SequenceSettings getSequenceSettings()(Code) Implementation of the getSequenceSettings method in com.sun.xml.ws.rm.api.client.ClientSequence. Need to populate the sequence ids in the returned SequenceSettings object, since in general, they will not be set in the underlying SequenceConfig object. getService public Service getService()(Code) Accessor for the service field. getTransferWindowSize public int getTransferWindowSize()(Code) Return the hoped-for limit to number of stored messages. Currently the limit is not enforced, but as the number of stored messages approaches the limit, resends and ackRequests occur more frequently. isAckRequested protected synchronized boolean isAckRequested()(Code) Checks whether an ack should be requested. Currently checks whether the The algorithm checks whether the ackRequest deadline has elapsed. The ackRequestDeadline is determined by the ackRequestInterval in the SequenceConfig member for this sequence. isAnonymous public boolean isAnonymous()(Code) Return value is determined by whether the destination endpoint is the anonymous URI. true if the destination is the anonymous URI.false otherwise. isResendDue public synchronized boolean isResendDue()(Code) Checks whether a resend should happen. The algorithm checks whether the resendDeadline has elapsed. The resendDeadline is determined by the resendInterval in the SequenceConfig member for this sequence. isSecureReliableMessaging public boolean isSecureReliableMessaging()(Code) isTransferWindowFull public boolean isTransferWindowFull()(Code) Returns true if TransferWindow is full. In this case, we hold off on sending messages. registerProtocolMessageSender public void registerProtocolMessageSender(ProtocolMessageSender pms)(Code) requestAck public synchronized void requestAck()(Code) Forces an ack request on next message resend public void resend(int messageNumber) throws RMException(Code) Causes the specified message number to be resent. Parameters:   messageNumber - The message number to resend setAcknowledgementListener public void setAcknowledgementListener(AcknowledgementListener listener)(Code) Registers a AcknowledgementListener for this sequence Parameters:   listener - The AcknowledgementListener setReceiveBufferSize public void setReceiveBufferSize(int receiveBufferSize)(Code) Mutator for the receiveBufferSize field. Parameters:   receiveBufferSize - The new value for the field. setSecureReliableMessaging public void setSecureReliableMessaging(boolean secureReliableMessaging)(Code) setSecurityTokenReference public void setSecurityTokenReference(JAXBElement<SecurityTokenReferenceType> str)(Code) setService public void setService(Service service)(Code) Sets the value of the service field. Parameters:   service - The service using the sequence. Fields inherited from com.sun.xml.ws.rm.jaxws.runtime.OutboundSequence protected AcknowledgementHandler ackHandler(Code)(Java Doc) protected URI acksTo(Code)(Java Doc) protected int bufferRemaining(Code)(Java Doc) protected URI destination(Code)(Java Doc) protected InboundSequence inboundSequence(Code)(Java Doc) public boolean saveMessages(Code)(Java Doc) protected AbstractSequenceAcknowledgement sequenceAcknowledgement(Code)(Java Doc) Methods inherited from com.sun.xml.ws.rm.jaxws.runtime.OutboundSequence public synchronized void acknowledge(int i) throws InvalidMessageNumberException(Code)(Java Doc) protected com.sun.xml.ws.api.message.Header createHeader(Object obj)(Code)(Java Doc) public void ensureAckRequested(Message mess, Marshaller marshaller)(Code)(Java Doc) public URI getAcksTo()(Code)(Java Doc) public int getBufferRemaining()(Code)(Java Doc) public URI getDestination()(Code)(Java Doc) public InboundSequence getInboundSequence()(Code)(Java Doc) public Message getUnacknowledgedMessage()(Code)(Java Doc) public void handleAckResponse(AbstractSequenceAcknowledgement element) throws InvalidMessageNumberException(Code)(Java Doc) protected boolean isAckRequested()(Code)(Java Doc) protected boolean isResendDue()(Code)(Java Doc) public synchronized void processAcknowledgement(Message mess, Marshaller marshaller) throws RMException(Code)(Java Doc) public void processOutboundMessage(Message mess, Marshaller marshaller) throws InvalidMessageNumberException, BufferFullException, DuplicateMessageException(Code)(Java Doc) public void setBufferRemaining(int value)(Code)(Java Doc) public void setProcessingFilter(ProcessingFilter filter)(Code)(Java Doc) public void setSequenceAcknowledgement(AbstractSequenceAcknowledgement element)(Code)(Java Doc) public synchronized void waitForAcks()(Code)(Java Doc)