Java Doc for OutboundSequence.java in  » 6.0-JDK-Modules-com.sun » wsit » com » sun » xml » ws » rm » jaxws » runtime » 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 
Source Cross Reference  Class Diagram Java Document (Java Doc) 


java.lang.Object
   com.sun.xml.ws.rm.Sequence
      com.sun.xml.ws.rm.jaxws.runtime.OutboundSequence

All known Subclasses:   com.sun.xml.ws.rm.jaxws.runtime.client.ClientOutboundSequence,  com.sun.xml.ws.rm.jaxws.runtime.server.ServerOutboundSequence,
OutboundSequence
abstract public class OutboundSequence extends Sequence (Code)


Field Summary
protected  AcknowledgementHandlerackHandler
     Instance of helper class that processes SequnceAcknowledgement headers.
protected  URIacksTo
     Endpoint for protocol responses.
protected  intbufferRemaining
     Space available in receiving buffer at destination, if this can be determined.
protected  URIdestination
     Common destination for all application messages in the sequence.
protected  InboundSequenceinboundSequence
    
public  booleansaveMessages
     Flag determines whether messages will be saved.
protected  AbstractSequenceAcknowledgementsequenceAcknowledgement
     Sequence acknowledgement to be sent back to client on next available message to the AcksTo endpoint.


Method Summary
public synchronized  voidacknowledge(int i)
     Sets the state of the message at the specified index to complete, and discards a com.sun.xml.ws.api.message.Message.
protected  com.sun.xml.ws.api.message.HeadercreateHeader(Object obj)
    
public  voidensureAckRequested(Message mess, Marshaller marshaller)
     Add AckRequested element to an existing message if one is not already present.
public  URIgetAcksTo()
     Accessor for the value of the Destination URI.
public  intgetBufferRemaining()
     Accessor for bufferRemaining field.
public  URIgetDestination()
     Accessor for the value of the Destination URI.
public  InboundSequencegetInboundSequence()
     Accessor for the inboundSequence field.
public  MessagegetUnacknowledgedMessage()
    
public  voidhandleAckResponse(AbstractSequenceAcknowledgement element)
     Removes acked messages from list.
protected  booleanisAckRequested()
    
protected  booleanisResendDue()
    
public synchronized  voidprocessAcknowledgement(Message mess, Marshaller marshaller)
     Add a pending acknowledgement to a message without adding message to sequence.
public  voidprocessOutboundMessage(Message mess, Marshaller marshaller)
     Handles an OutboundMessage.
public  voidsetBufferRemaining(int value)
     Mutator for bufferRemaining field.
public  voidsetProcessingFilter(ProcessingFilter filter)
    
public  voidsetSequenceAcknowledgement(AbstractSequenceAcknowledgement element)
    
public synchronized  voidwaitForAcks()
     Called by disconnect before sending Last and Terminate sequence.

Field Detail
ackHandler
protected AcknowledgementHandler ackHandler(Code)
Instance of helper class that processes SequnceAcknowledgement headers.



acksTo
protected URI acksTo(Code)
Endpoint for protocol responses. May be the WS-Addressing anonymous endpoint. There are several variations depending on whether this EPR is the same as the one used by application messages in the companion InboundSequence



bufferRemaining
protected int bufferRemaining(Code)
Space available in receiving buffer at destination, if this can be determined.



destination
protected URI destination(Code)
Common destination for all application messages in the sequence.



inboundSequence
protected InboundSequence inboundSequence(Code)
Companion InboundSequence



saveMessages
public boolean saveMessages(Code)
Flag determines whether messages will be saved. Will only be false in the case of companions to ServerInboundSequences for endpoints with no two-way operations.



sequenceAcknowledgement
protected AbstractSequenceAcknowledgement sequenceAcknowledgement(Code)
Sequence acknowledgement to be sent back to client on next available message to the AcksTo endpoint.





Method Detail
acknowledge
public synchronized void acknowledge(int i) throws InvalidMessageNumberException(Code)
Sets the state of the message at the specified index to complete, and discards a com.sun.xml.ws.api.message.Message.
Parameters:
  i - Index to set.



createHeader
protected com.sun.xml.ws.api.message.Header createHeader(Object obj)(Code)



ensureAckRequested
public void ensureAckRequested(Message mess, Marshaller marshaller)(Code)
Add AckRequested element to an existing message if one is not already present. This is used to ensure that an AckRequested header is included on every resend.
Parameters:
  mess - The message
Parameters:
  marshaller -



getAcksTo
public URI getAcksTo()(Code)
Accessor for the value of the Destination URI. The destination String.



getBufferRemaining
public int getBufferRemaining()(Code)
Accessor for bufferRemaining field.



getDestination
public URI getDestination()(Code)
Accessor for the value of the Destination URI. The destination URI.



getInboundSequence
public InboundSequence getInboundSequence()(Code)
Accessor for the inboundSequence field. The inboundSequence field.



getUnacknowledgedMessage
public Message getUnacknowledgedMessage()(Code)



handleAckResponse
public void handleAckResponse(AbstractSequenceAcknowledgement element) throws InvalidMessageNumberException(Code)
Removes acked messages from list. (For anonymous client, need to widen definition of acked to include the requirement that responses have arrived.)
Parameters:
  element - The SequenceAcknowledgementElement containing theranges of messages to be removed.



isAckRequested
protected boolean isAckRequested()(Code)



isResendDue
protected boolean isResendDue()(Code)



processAcknowledgement
public synchronized void processAcknowledgement(Message mess, Marshaller marshaller) throws RMException(Code)
Add a pending acknowledgement to a message without adding message to sequence. Used for sending final ack on a TerminateSequence message if necessary.
Parameters:
  mess - The OutboundMessage.
Parameters:
  marshaller - The Marshaller to use



processOutboundMessage
public void processOutboundMessage(Message mess, Marshaller marshaller) throws InvalidMessageNumberException, BufferFullException, DuplicateMessageException(Code)
Handles an OutboundMessage.
  • Store the message
  • If ackRequested flag is set, add an AckRequestedElement header to the message.
  • If complanion ClientInboundSequence has queued an acknowledgement, add a SequenceAcknowledgementElement header to the message.

Parameters:
  mess - The OutboundMessage.
Parameters:
  marshaller - The Marshaller to use



setBufferRemaining
public void setBufferRemaining(int value)(Code)
Mutator for bufferRemaining field.



setProcessingFilter
public void setProcessingFilter(ProcessingFilter filter)(Code)



setSequenceAcknowledgement
public void setSequenceAcknowledgement(AbstractSequenceAcknowledgement element)(Code)
Invoked by Incoming message processor to post Sequence Acknowledgement from companion Incoming Sequence for transmission on next OutboundMessage.l



waitForAcks
public synchronized void waitForAcks()(Code)
Called by disconnect before sending Last and Terminate sequence. Blocks until all messages have been acked. The notifyAll method is called by OutboundSequence.acknowledge when stored message count reaches 0.



Fields inherited from com.sun.xml.ws.rm.Sequence
protected boolean allowDuplicates(Code)(Java Doc)
protected boolean closed(Code)(Java Doc)
protected SequenceConfig config(Code)(Java Doc)
protected int firstKnownGap(Code)(Java Doc)
protected String id(Code)(Java Doc)
protected boolean last(Code)(Java Doc)
protected long lastActivityTime(Code)(Java Doc)
protected ArrayList<Message> list(Code)(Java Doc)
protected int maxMessages(Code)(Java Doc)
protected int nextIndex(Code)(Java Doc)
protected RMConstants rmConstants(Code)(Java Doc)
protected int storedMessages(Code)(Java Doc)

Methods inherited from com.sun.xml.ws.rm.Sequence
public synchronized Message get(int index) throws InvalidMessageNumberException(Code)(Java Doc)
public String getId()(Code)(Java Doc)
protected long getLastActivityTime()(Code)(Java Doc)
public synchronized int getNextIndex()(Code)(Java Doc)
public SequenceConfig getSequenceConfig()(Code)(Java Doc)
public synchronized boolean isClosed()(Code)(Java Doc)
protected boolean isGettingClose(long elapsedTime, long timeLimit)(Code)(Java Doc)
public synchronized boolean isLast()(Code)(Java Doc)
public void resetLastActivityTime()(Code)(Java Doc)
public synchronized int set(int i, Message m) throws InvalidMessageNumberException, BufferFullException, DuplicateMessageException(Code)(Java Doc)
public synchronized void setClosed()(Code)(Java Doc)
public void setId(String id)(Code)(Java Doc)
public synchronized void setLast()(Code)(Java Doc)

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)

w___ww__._j_a___v_a___2__s__._co_m___ | Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.