jbossws-commits September 2007

jbossws-commits@lists.jboss.org

1 participants
143 discussions

JBossWS SVN: r4512 - in stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm: spi/protocol and 1 other directory.

by jbossws-commits＠lists.jboss.org

Author: richard.opalka(a)jboss.com Date: 2007-09-03 13:22:47 -0400 (Mon, 03 Sep 2007) New Revision: 4512 Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/AckRequestedImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceResponseImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceResponseImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceAcknowledgementImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceFaultImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceResponseImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/AckRequested.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/CloseSequence.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/CreateSequenceResponse.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/SequenceAcknowledgement.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/TerminateSequence.java Log: adding WS-RM 2007/02 initial implementation except de/serialization support Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/AckRequestedImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/AckRequestedImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/AckRequestedImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -21,6 +21,7 @@ */ package org.jboss.ws.extensions.wsrm.spec200702; +import org.jboss.util.NotImplementedException; import org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested; import org.w3c.dom.Element; @@ -31,6 +32,8 @@ final class AckRequestedImpl implements AckRequested { + private String identifier; + AckRequestedImpl() { // allow inside package use only @@ -41,17 +44,15 @@ */ public String getIdentifier() { - // TODO Auto-generated method stub - return null; + return this.identifier; } /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested#getMessage() */ - public long getMessage() + public long getMessageNumber() { - // TODO Auto-generated method stub - return 0; + return 0; // always return zero for this version of the RM protocol } /* @@ -59,17 +60,20 @@ */ public void setIdentifier(String identifier) { - // TODO Auto-generated method stub - + if ((identifier == null) || (identifier.trim().equals(""))) + throw new IllegalArgumentException("Identifier cannot be null nor empty string"); + if (this.identifier != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.identifier = identifier; } /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested#setMessage(long) */ - public void setMessage(long lastMessageId) + public void setMessageNumber(long lastMessageNumber) { - // TODO Auto-generated method stub - + // do nothing for this version of the RM protocol } /* @@ -77,8 +81,9 @@ */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } /* @@ -86,8 +91,15 @@ */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } - + + private void ensureLegalState() + { + if (this.identifier == null) + throw new IllegalStateException(); + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -21,6 +21,7 @@ */ package org.jboss.ws.extensions.wsrm.spec200702; +import org.jboss.util.NotImplementedException; import org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence; import org.w3c.dom.Element; @@ -31,6 +32,9 @@ final class CloseSequenceImpl implements CloseSequence { + private String identifier; + private long lastMsgNumber; + CloseSequenceImpl() { // allow inside package use only @@ -41,17 +45,15 @@ */ public String getIdentifier() { - // TODO Auto-generated method stub - return null; + return this.identifier; } /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence#getLastMsgNumber() */ - public void getLastMsgNumber() + public long getLastMsgNumber() { - // TODO Auto-generated method stub - + return this.lastMsgNumber; } /* @@ -59,8 +61,12 @@ */ public void setIdentifier(String identifier) { - // TODO Auto-generated method stub - + if ((identifier == null) || (identifier.trim().equals(""))) + throw new IllegalArgumentException("Identifier cannot be null nor empty string"); + if (this.identifier != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.identifier = identifier; } /* @@ -68,8 +74,12 @@ */ public void setLastMsgNumber(long lastMsgNumber) { - // TODO Auto-generated method stub - + if (lastMsgNumber <= 0) + throw new IllegalArgumentException("Value must be greater than 0"); + if (this.lastMsgNumber > 0) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.lastMsgNumber = lastMsgNumber; } /* @@ -77,8 +87,9 @@ */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } /* @@ -86,8 +97,15 @@ */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } + private void ensureLegalState() + { + if (this.identifier == null) + throw new IllegalStateException(); + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceResponseImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceResponseImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceResponseImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -21,6 +21,7 @@ */ package org.jboss.ws.extensions.wsrm.spec200702; +import org.jboss.util.NotImplementedException; import org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequenceResponse; import org.w3c.dom.Element; @@ -31,6 +32,8 @@ final class CloseSequenceResponseImpl implements CloseSequenceResponse { + private String identifier; + CloseSequenceResponseImpl() { // allow inside package use only @@ -41,8 +44,7 @@ */ public String getIdentifier() { - // TODO Auto-generated method stub - return null; + return this.identifier; } /* @@ -50,8 +52,12 @@ */ public void setIdentifier(String identifier) { - // TODO Auto-generated method stub - + if ((identifier == null) || (identifier.trim().equals(""))) + throw new IllegalArgumentException("Identifier cannot be null nor empty string"); + if (this.identifier != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.identifier = identifier; } /* @@ -59,8 +65,9 @@ */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } /* @@ -68,8 +75,15 @@ */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } + private void ensureLegalState() + { + if (this.identifier == null) + throw new IllegalStateException(); + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -21,7 +21,9 @@ */ package org.jboss.ws.extensions.wsrm.spec200702; +import org.jboss.util.NotImplementedException; import org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence; +import org.jboss.ws.extensions.wsrm.spi.protocol.IncompleteSequenceBehavior; import org.w3c.dom.Element; /* @@ -30,6 +32,10 @@ */ final class CreateSequenceImpl implements CreateSequence { + + private String acksTo; + private String expires; + private Offer offer; CreateSequenceImpl() { @@ -41,8 +47,7 @@ */ public String getAcksTo() { - // TODO Auto-generated method stub - return null; + return this.acksTo; } /* @@ -50,8 +55,7 @@ */ public String getExpires() { - // TODO Auto-generated method stub - return null; + return this.expires; } /* @@ -59,8 +63,7 @@ */ public Offer getOffer() { - // TODO Auto-generated method stub - return null; + return this.offer; } /* @@ -68,8 +71,7 @@ */ public Offer newOffer() { - // TODO Auto-generated method stub - return null; + return new OfferImpl(); } /* @@ -77,8 +79,12 @@ */ public void setAcksTo(String address) { - // TODO Auto-generated method stub - + if ((address == null) || (address.trim().equals(""))) + throw new IllegalArgumentException("Address cannot be null nor empty string"); + if (this.acksTo != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.acksTo = address; } /* @@ -86,8 +92,12 @@ */ public void setExpires(String duration) { - // TODO Auto-generated method stub - + if ((duration == null) || (duration.trim().equals(""))) + throw new IllegalArgumentException("Duration cannot be null nor empty string"); + if (this.expires != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.expires = duration; } /* @@ -95,8 +105,14 @@ */ public void setOffer(Offer offer) { - // TODO Auto-generated method stub - + if (offer == null) + throw new IllegalArgumentException("Offer cannot be null"); + if (!(offer instanceof OfferImpl)) + throw new IllegalArgumentException(); + if (this.offer != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.offer = offer; } /* @@ -104,8 +120,9 @@ */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } /* @@ -113,8 +130,144 @@ */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } + private void ensureLegalState() + { + if (this.acksTo == null) + throw new IllegalStateException(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer + */ + private static final class OfferImpl implements CreateSequence.Offer + { + + private String endpoint; + private String duration; + private String identifier; + private IncompleteSequenceBehavior incompleteSequenceBehavior; + + private OfferImpl() + { + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer#getEndpoint() + */ + public String getEndpoint() + { + return this.endpoint; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer#getExpires() + */ + public String getExpires() + { + return this.duration; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer#getIdentifier() + */ + public String getIdentifier() + { + return this.identifier; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer#getIncompleteSequenceBehavior() + */ + public IncompleteSequenceBehavior getIncompleteSequenceBehavior() + { + return this.incompleteSequenceBehavior; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer#setEndpoint(java.lang.String) + */ + public void setEndpoint(String address) + { + if ((address == null) || (address.trim().equals(""))) + throw new IllegalArgumentException("Address cannot be null nor empty string"); + if (this.endpoint != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.endpoint = address; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer#setExpires(java.lang.String) + */ + public void setExpires(String duration) + { + if ((duration == null) || (duration.trim().equals(""))) + throw new IllegalArgumentException("Duration cannot be null nor empty string"); + if (this.duration != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.duration = duration; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer#setIdentifier(java.lang.String) + */ + public void setIdentifier(String identifier) + { + if ((identifier == null) || (identifier.trim().equals(""))) + throw new IllegalArgumentException("Identifier cannot be null nor empty string"); + if (this.identifier != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.identifier = identifier; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer#setIncompleteSequenceBehavior(org.jboss.ws.extensions.wsrm.spi.protocol.IncompleteSequenceBehavior) + */ + public void setIncompleteSequenceBehavior(IncompleteSequenceBehavior incompleteSequenceBehavior) + { + if (incompleteSequenceBehavior == null) + throw new IllegalArgumentException("Sequence behavior type cannot be null"); + if (this.incompleteSequenceBehavior != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.incompleteSequenceBehavior = incompleteSequenceBehavior; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); + } + + private void ensureLegalState() + { + if (this.identifier == null) + throw new IllegalStateException(); + if (this.endpoint == null) + throw new IllegalStateException(); + } + + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceResponseImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceResponseImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceResponseImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -21,6 +21,7 @@ */ package org.jboss.ws.extensions.wsrm.spec200702; +import org.jboss.util.NotImplementedException; import org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse; import org.jboss.ws.extensions.wsrm.spi.protocol.IncompleteSequenceBehavior; import org.w3c.dom.Element; @@ -31,6 +32,11 @@ */ final class CreateSequenceResponseImpl implements CreateSequenceResponse { + + private String identifier; + private String expires; + private Accept accept; + private IncompleteSequenceBehavior incompleteSequenceBehavior; CreateSequenceResponseImpl() { @@ -42,17 +48,15 @@ */ public Accept getAccept() { - // TODO Auto-generated method stub - return null; + return this.accept; } /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#getDuration() */ - public String getDuration() + public String getExpires() { - // TODO Auto-generated method stub - return null; + return this.expires; } /* @@ -60,8 +64,7 @@ */ public String getIdentifier() { - // TODO Auto-generated method stub - return null; + return this.identifier; } /* @@ -69,8 +72,7 @@ */ public IncompleteSequenceBehavior getIncompleteSequenceBehavior() { - // TODO Auto-generated method stub - return null; + return this.incompleteSequenceBehavior; } /* @@ -78,8 +80,7 @@ */ public Accept newAccept() { - // TODO Auto-generated method stub - return null; + return new AcceptImpl(); } /* @@ -87,8 +88,14 @@ */ public void setAccept(Accept accept) { - // TODO Auto-generated method stub - + if (accept == null) + throw new IllegalArgumentException("Accept cannot be null"); + if (!(accept instanceof AcceptImpl)) + throw new IllegalArgumentException(); + if (this.accept != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.accept = accept; } /* @@ -96,8 +103,12 @@ */ public void setExpires(String duration) { - // TODO Auto-generated method stub - + if ((duration == null) || (duration.trim().equals(""))) + throw new IllegalArgumentException("Duration cannot be null nor empty string"); + if (this.expires != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.expires = duration; } /* @@ -105,17 +116,25 @@ */ public void setIdentifier(String identifier) { - // TODO Auto-generated method stub - + if ((identifier == null) || (identifier.trim().equals(""))) + throw new IllegalArgumentException("Identifier cannot be null nor empty string"); + if (this.identifier != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.identifier = identifier; } /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#setIncompleteSequenceBehavior(org.jboss.ws.extensions.wsrm.spi.protocol.IncompleteSequenceBehavior) */ - public void setIncompleteSequenceBehavior(IncompleteSequenceBehavior incompletSequenceBehaviour) + public void setIncompleteSequenceBehavior(IncompleteSequenceBehavior incompleteSequenceBehavior) { - // TODO Auto-generated method stub - + if (incompleteSequenceBehavior == null) + throw new IllegalArgumentException("Sequence behavior type cannot be null"); + if (this.incompleteSequenceBehavior != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.incompleteSequenceBehavior = incompleteSequenceBehavior; } /* @@ -123,8 +142,9 @@ */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } /* @@ -132,8 +152,72 @@ */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } + + private void ensureLegalState() + { + if (this.identifier == null) + throw new IllegalStateException(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse.Accept + */ + private static final class AcceptImpl implements CreateSequenceResponse.Accept + { + private String acksTo; + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse.Accept#getAcksTo() + */ + public String getAcksTo() + { + return this.acksTo; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse.Accept#setAcksTo(java.lang.String) + */ + public void setAcksTo(String address) + { + if ((address == null) || (address.trim().equals(""))) + throw new IllegalArgumentException("Address cannot be null nor empty string"); + if (this.acksTo != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.acksTo = address; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); + } + + private void ensureLegalState() + { + if (this.acksTo == null) + throw new IllegalStateException(); + } + + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -48,7 +48,7 @@ * @see org.jboss.ws.extensions.wsrm.spi.Provider#getMessageFactory() */ @Override - public final MessageFactory getMessageFactory() + public MessageFactory getMessageFactory() { return MessageFactoryImpl.getInstance(); } @@ -57,7 +57,7 @@ * @see org.jboss.ws.extensions.wsrm.spi.Provider#getNamespaceURI() */ @Override - public final String getNamespaceURI() + public String getNamespaceURI() { return IMPLEMENTATION_VERSION; } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceAcknowledgementImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceAcknowledgementImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceAcknowledgementImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -22,7 +22,10 @@ package org.jboss.ws.extensions.wsrm.spec200702; import java.util.List; +import java.util.LinkedList; +import java.util.Collections; +import org.jboss.util.NotImplementedException; import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement; import org.w3c.dom.Element; @@ -33,6 +36,12 @@ final class SequenceAcknowledgementImpl implements SequenceAcknowledgement { + private final List<Long> nacks = new LinkedList<Long>(); + private final List<AcknowledgementRange> acknowledgementRanges = new LinkedList<AcknowledgementRange>(); + private String identifier; + private boolean isFinal; + private boolean isNone; + SequenceAcknowledgementImpl() { // allow inside package use only @@ -41,10 +50,20 @@ /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#addAcknowledgementRange(org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement.AcknowledgementRange) */ - public void addAcknowledgementRange(AcknowledgementRange acknowledgementRange) + public void addAcknowledgementRange(AcknowledgementRange newAcknowledgementRange) { - // TODO Auto-generated method stub - + if ((newAcknowledgementRange == null) || (!(newAcknowledgementRange instanceof AcknowledgementRangeImpl))) + throw new IllegalArgumentException(); + if (this.nacks.size() != 0) + throw new IllegalStateException("There are already some nacks specified"); + if (this.isNone) + throw new IllegalStateException("There is already none specified"); + if ((newAcknowledgementRange.getLower() == 0) || (newAcknowledgementRange.getUpper() == 0)) + throw new IllegalArgumentException("Both, lower and upper values must be specified"); + for (AcknowledgementRange alreadyAccepted : acknowledgementRanges) + checkOverlap(alreadyAccepted, newAcknowledgementRange); + + this.acknowledgementRanges.add(newAcknowledgementRange); } /* @@ -52,8 +71,16 @@ */ public void addNack(long messageNumber) { - // TODO Auto-generated method stub + if (this.isFinal) + throw new IllegalStateException("There is already final specified"); + if (this.isNone) + throw new IllegalStateException("There is already none specified"); + if (this.acknowledgementRanges.size() != 0) + throw new IllegalStateException("There are already some acknowledgement ranges specified"); + if (this.nacks.contains(messageNumber)) + throw new IllegalArgumentException("There is already nack with value " + messageNumber + " specified"); + this.nacks.add(messageNumber); } /* @@ -61,8 +88,7 @@ */ public List<AcknowledgementRange> getAcknowledgementRanges() { - // TODO Auto-generated method stub - return null; + return Collections.unmodifiableList(acknowledgementRanges); } /* @@ -70,8 +96,7 @@ */ public String getIdentifier() { - // TODO Auto-generated method stub - return null; + return this.identifier; } /* @@ -79,8 +104,7 @@ */ public List<Long> getNacks() { - // TODO Auto-generated method stub - return null; + return Collections.unmodifiableList(nacks); } /* @@ -88,8 +112,7 @@ */ public boolean isFinal() { - // TODO Auto-generated method stub - return false; + return this.isFinal; } /* @@ -97,8 +120,7 @@ */ public boolean isNone() { - // TODO Auto-generated method stub - return false; + return this.isNone; } /* @@ -106,17 +128,18 @@ */ public AcknowledgementRange newAcknowledgementRange() { - // TODO Auto-generated method stub - return null; + return new AcknowledgementRangeImpl(); } /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#setFinal(boolean) */ - public void setFinal(boolean isFinal) + public void setFinal() { - // TODO Auto-generated method stub + if (this.nacks.size() != 0) + throw new IllegalStateException("There are already some nacks specified"); + this.isFinal = true; } /* @@ -124,17 +147,25 @@ */ public void setIdentifier(String identifier) { - // TODO Auto-generated method stub - + if ((identifier == null) || (identifier.trim().equals(""))) + throw new IllegalArgumentException("Identifier cannot be null nor empty string"); + if (this.identifier != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.identifier = identifier; } /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#setNone(boolean) */ - public void setNone(boolean isNone) + public void setNone() { - // TODO Auto-generated method stub - + if (this.acknowledgementRanges.size() != 0) + throw new IllegalStateException("There are already some acknowledgement ranges specified"); + if (this.nacks.size() != 0) + throw new IllegalStateException("There are already some nacks specified"); + + this.isNone = true; } /* @@ -142,17 +173,122 @@ */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } - + /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } + + private void ensureLegalState() + { + if ((this.acknowledgementRanges.size() == 0) && (this.nacks.size() == 0) && (!this.isNone)) + throw new IllegalStateException(); + } + private static void checkOverlap(AcknowledgementRange currentRange, AcknowledgementRange newRange) + { + if ((currentRange.getLower() <= newRange.getLower()) && (newRange.getLower() <= currentRange.getUpper())) + throw new IllegalArgumentException( + "Overlap detected: " + currentRange + " vs. " + newRange); + if ((currentRange.getLower() <= newRange.getUpper()) && (newRange.getUpper() <= currentRange.getUpper())) + throw new IllegalArgumentException( + "Overlap detected: " + currentRange + " vs. " + newRange); + } + + private static final class AcknowledgementRangeImpl implements SequenceAcknowledgement.AcknowledgementRange + { + + private long lower; + private long upper; + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement.AcknowledgementRange#getLower() + */ + public long getLower() + { + return this.lower; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement.AcknowledgementRange#getUpper() + */ + public long getUpper() + { + return this.upper; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement.AcknowledgementRange#setLower(long) + */ + public void setLower(long lower) + { + if (lower <= 0) + throw new IllegalArgumentException("Value must be greater than 0"); + if (this.lower > 0) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + if ((this.upper > 0) && (lower > this.upper)) + throw new IllegalArgumentException("Value must be lower or equal to " + this.upper); + + this.lower = lower; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement.AcknowledgementRange#setUpper(long) + */ + public void setUpper(long upper) + { + if (upper <= 0) + throw new IllegalArgumentException("Value must be greater than 0"); + if (this.upper > 0) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + if ((this.lower > 0) && (this.lower > upper)) + throw new IllegalArgumentException("Value must be greater or equal to " + this.lower); + + this.upper = upper; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); + } + + public String toString() + { + return "<" + lower + "; " + upper + ">"; + } + + private void ensureLegalState() + { + if (this.lower == 0) + throw new IllegalStateException(); + if (this.upper == 0) + throw new IllegalStateException(); + } + + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceFaultImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceFaultImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceFaultImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -21,6 +21,7 @@ */ package org.jboss.ws.extensions.wsrm.spec200702; +import org.jboss.util.NotImplementedException; import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFault; import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFaultCode; import org.w3c.dom.Element; @@ -31,6 +32,9 @@ */ final class SequenceFaultImpl implements SequenceFault { + + private SequenceFaultCode faultCode; + private Exception detail; SequenceFaultImpl() { @@ -42,8 +46,7 @@ */ public Exception getDetail() { - // TODO Auto-generated method stub - return null; + return this.detail; } /* @@ -51,8 +54,7 @@ */ public SequenceFaultCode getFaultCode() { - // TODO Auto-generated method stub - return null; + return this.faultCode; } /* @@ -60,8 +62,12 @@ */ public void setDetail(Exception detail) { - // TODO Auto-generated method stub + if (detail == null) + throw new IllegalArgumentException("Detail cannot be null"); + if (this.detail != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + this.detail = detail; } /* @@ -69,8 +75,12 @@ */ public void setFaultCode(SequenceFaultCode faultCode) { - // TODO Auto-generated method stub + if (faultCode == null) + throw new IllegalArgumentException("Fault code cannot be null"); + if (this.faultCode != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + this.faultCode = faultCode; } /* @@ -78,8 +88,9 @@ */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } /* @@ -87,8 +98,15 @@ */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } + private void ensureLegalState() + { + if (this.faultCode == null) + throw new IllegalStateException(); + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -23,6 +23,7 @@ import org.jboss.ws.extensions.wsrm.spi.protocol.Sequence; import org.w3c.dom.Element; +import org.jboss.util.NotImplementedException; /* * @author richard.opalka(a)jboss.com @@ -30,6 +31,9 @@ */ final class SequenceImpl implements Sequence { + + private String identifier; + private long messageNumber; SequenceImpl() { @@ -41,8 +45,7 @@ */ public String getIdentifier() { - // TODO Auto-generated method stub - return null; + return this.identifier; } /* @@ -50,8 +53,7 @@ */ public long getMessageNumber() { - // TODO Auto-generated method stub - return 0; + return messageNumber; } /* @@ -59,8 +61,7 @@ */ public boolean isLastMessage() { - // TODO Auto-generated method stub - return false; + return false; // always return false for this version of the RM protocol } /* @@ -68,8 +69,12 @@ */ public void setIdentifier(String identifier) { - // TODO Auto-generated method stub - + if ((identifier == null) || (identifier.trim().equals(""))) + throw new IllegalArgumentException("Identifier cannot be null nor empty string"); + if (this.identifier != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.identifier = identifier; } /* @@ -77,8 +82,7 @@ */ public void setLastMessage(boolean lastMessage) { - // TODO Auto-generated method stub - + // do nothing for this version of the RM protocol } /* @@ -86,17 +90,22 @@ */ public void setMessageNumber(long messageNumber) { - // TODO Auto-generated method stub - + if (messageNumber <= 0) + throw new IllegalArgumentException("Value must be greater than 0"); + if (this.messageNumber > 0) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.messageNumber = messageNumber; } - + /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } /* @@ -104,8 +113,17 @@ */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } + private void ensureLegalState() + { + if (this.identifier == null) + throw new IllegalStateException(); + if (this.messageNumber == 0) + throw new IllegalStateException(); + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -21,6 +21,7 @@ */ package org.jboss.ws.extensions.wsrm.spec200702; +import org.jboss.util.NotImplementedException; import org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence; import org.w3c.dom.Element; @@ -31,6 +32,9 @@ final class TerminateSequenceImpl implements TerminateSequence { + private String identifier; + private long lastMsgNumber; + TerminateSequenceImpl() { // allow inside package use only @@ -41,17 +45,15 @@ */ public String getIdentifier() { - // TODO Auto-generated method stub - return null; + return this.identifier; } /* * @see org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence#getLastMsgNumber() */ - public void getLastMsgNumber() + public long getLastMsgNumber() { - // TODO Auto-generated method stub - + return this.lastMsgNumber; } /* @@ -59,8 +61,12 @@ */ public void setIdentifier(String identifier) { - // TODO Auto-generated method stub - + if ((identifier == null) || (identifier.trim().equals(""))) + throw new IllegalArgumentException("Identifier cannot be null nor empty string"); + if (this.identifier != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.identifier = identifier; } /* @@ -68,8 +74,12 @@ */ public void setLastMsgNumber(long lastMsgNumber) { - // TODO Auto-generated method stub - + if (lastMsgNumber <= 0) + throw new IllegalArgumentException("Value must be greater than 0"); + if (this.lastMsgNumber > 0) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.lastMsgNumber = lastMsgNumber; } /* @@ -77,8 +87,9 @@ */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } /* @@ -86,8 +97,15 @@ */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } + private void ensureLegalState() + { + if (this.identifier == null) + throw new IllegalStateException(); + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceResponseImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceResponseImpl.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceResponseImpl.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -21,6 +21,7 @@ */ package org.jboss.ws.extensions.wsrm.spec200702; +import org.jboss.util.NotImplementedException; import org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequenceResponse; import org.w3c.dom.Element; @@ -31,6 +32,8 @@ final class TerminateSequenceResponseImpl implements TerminateSequenceResponse { + private String identifier; + TerminateSequenceResponseImpl() { // allow inside package use only @@ -41,8 +44,7 @@ */ public String getIdentifier() { - // TODO Auto-generated method stub - return null; + return this.identifier; } /* @@ -50,8 +52,12 @@ */ public void setIdentifier(String identifier) { - // TODO Auto-generated method stub - + if ((identifier == null) || (identifier.trim().equals(""))) + throw new IllegalArgumentException("Identifier cannot be null nor empty string"); + if (this.identifier != null) + throw new UnsupportedOperationException("Value already set, cannot be overriden"); + + this.identifier = identifier; } /* @@ -59,8 +65,9 @@ */ public void fromXML(Element e) { - // TODO Auto-generated method stub - + // TODO: implement deserialization using object set methods + if (true) throw new NotImplementedException(); + ensureLegalState(); } /* @@ -68,8 +75,15 @@ */ public Element toXML() { - // TODO Auto-generated method stub - return null; + ensureLegalState(); + // TODO implement serialization using object instance fields + throw new NotImplementedException(); } + private void ensureLegalState() + { + if (this.identifier == null) + throw new IllegalStateException(); + } + } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/AckRequested.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/AckRequested.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/AckRequested.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -57,13 +57,13 @@ * MessageNumber sent by the RM Source within a Sequence. If present, it MAY be treated * as a hint to the RM Destination as an optimization to the process of preparing to transmit a * SequenceAcknowledgement. - * @param lastMessageId + * @param lastMessageNumber */ - void setMessage(long lastMessageId); + void setMessageNumber(long lastMessageNumber); /** * Getter * @return last message number in the sequence */ - long getMessage(); + long getMessageNumber(); } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/CloseSequence.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/CloseSequence.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/CloseSequence.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -65,5 +65,5 @@ * Getter * @return last message number */ - void getLastMsgNumber(); + long getLastMsgNumber(); } Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/CreateSequenceResponse.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/CreateSequenceResponse.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/CreateSequenceResponse.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -78,7 +78,7 @@ * Getter * @return sequence duration */ - String getDuration(); + String getExpires(); /** * This element, if present, specifies the behavior that the destination will exhibit upon the closure or Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/SequenceAcknowledgement.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/SequenceAcknowledgement.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/SequenceAcknowledgement.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -70,9 +70,8 @@ * Destination MUST include this element when the Sequence is closed. The RM Destination MUST * NOT include this element when sending a Nack; it can only be used when sending * AcknowledgementRange elements or a None. - * @param isFinal */ - void setFinal(boolean isFinal); + void setFinal(); /** * Getter @@ -85,9 +84,8 @@ * block if the RM Destination has not accepted any messages for the specified Sequence. The RM * Destination MUST NOT include this element if a sibling AcknowledgementRange or Nack * element is also present as a child of the SequenceAcknowledgement. - * @param isNone */ - void setNone(boolean isNone); + void setNone(); /** * Getter Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/TerminateSequence.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/TerminateSequence.java 2007-09-03 10:49:45 UTC (rev 4511) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/TerminateSequence.java 2007-09-03 17:22:47 UTC (rev 4512) @@ -74,5 +74,5 @@ * Getter * @return last message number */ - void getLastMsgNumber(); + long getLastMsgNumber(); }

16 years, 8 months

1
0
0 / 0

JBossWS SVN: r4511 - in stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm: spec200702 and 1 other directories.

by jbossws-commits＠lists.jboss.org

Author: richard.opalka(a)jboss.com Date: 2007-09-03 06:49:45 -0400 (Mon, 03 Sep 2007) New Revision: 4511 Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/AckRequestedImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceResponseImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceResponseImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/MessageFactoryImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceAcknowledgementImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceFaultImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceImpl.java stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceResponseImpl.java Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/Provider.java Log: adding new WS-RM provider to be implemented Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/AckRequestedImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/AckRequestedImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/AckRequestedImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,93 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested + */ +final class AckRequestedImpl implements AckRequested +{ + + AckRequestedImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested#getIdentifier() + */ + public String getIdentifier() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested#getMessage() + */ + public long getMessage() + { + // TODO Auto-generated method stub + return 0; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested#setIdentifier(java.lang.String) + */ + public void setIdentifier(String identifier) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested#setMessage(long) + */ + public void setMessage(long lastMessageId) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/AckRequestedImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,93 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence + */ +final class CloseSequenceImpl implements CloseSequence +{ + + CloseSequenceImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence#getIdentifier() + */ + public String getIdentifier() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence#getLastMsgNumber() + */ + public void getLastMsgNumber() + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence#setIdentifier(java.lang.String) + */ + public void setIdentifier(String identifier) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence#setLastMsgNumber(long) + */ + public void setLastMsgNumber(long lastMsgNumber) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceResponseImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceResponseImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceResponseImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,75 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequenceResponse; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequenceResponse + */ +final class CloseSequenceResponseImpl implements CloseSequenceResponse +{ + + CloseSequenceResponseImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequenceResponse#getIdentifier() + */ + public String getIdentifier() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequenceResponse#setIdentifier(java.lang.String) + */ + public void setIdentifier(String identifier) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CloseSequenceResponseImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,120 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence + */ +final class CreateSequenceImpl implements CreateSequence +{ + + CreateSequenceImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence#getAcksTo() + */ + public String getAcksTo() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence#getExpires() + */ + public String getExpires() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence#getOffer() + */ + public Offer getOffer() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence#newOffer() + */ + public Offer newOffer() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence#setAcksTo(java.lang.String) + */ + public void setAcksTo(String address) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence#setExpires(java.lang.String) + */ + public void setExpires(String duration) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence#setOffer(org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence.Offer) + */ + public void setOffer(Offer offer) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceResponseImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceResponseImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceResponseImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,139 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse; +import org.jboss.ws.extensions.wsrm.spi.protocol.IncompleteSequenceBehavior; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse + */ +final class CreateSequenceResponseImpl implements CreateSequenceResponse +{ + + CreateSequenceResponseImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#getAccept() + */ + public Accept getAccept() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#getDuration() + */ + public String getDuration() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#getIdentifier() + */ + public String getIdentifier() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#getIncompleteSequenceBehavior() + */ + public IncompleteSequenceBehavior getIncompleteSequenceBehavior() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#newAccept() + */ + public Accept newAccept() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#setAccept(org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse.Accept) + */ + public void setAccept(Accept accept) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#setExpires(java.lang.String) + */ + public void setExpires(String duration) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#setIdentifier(java.lang.String) + */ + public void setIdentifier(String identifier) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse#setIncompleteSequenceBehavior(org.jboss.ws.extensions.wsrm.spi.protocol.IncompleteSequenceBehavior) + */ + public void setIncompleteSequenceBehavior(IncompleteSequenceBehavior incompletSequenceBehaviour) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/CreateSequenceResponseImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/MessageFactoryImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/MessageFactoryImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/MessageFactoryImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,135 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.MessageFactory; +import org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested; +import org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence; +import org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequenceResponse; +import org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence; +import org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse; +import org.jboss.ws.extensions.wsrm.spi.protocol.Sequence; +import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement; +import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFault; +import org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence; +import org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequenceResponse; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory + */ +final class MessageFactoryImpl implements MessageFactory +{ + + private static final MessageFactory INSTANCE = new MessageFactoryImpl(); + + private MessageFactoryImpl() + { + // forbidden inheritance + } + + public static MessageFactory getInstance() + { + return INSTANCE; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newAckRequested() + */ + public AckRequested newAckRequested() + { + return new AckRequestedImpl(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newCloseSequence() + */ + public CloseSequence newCloseSequence() + { + return new CloseSequenceImpl(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newCloseSequenceResponse() + */ + public CloseSequenceResponse newCloseSequenceResponse() + { + return new CloseSequenceResponseImpl(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newCreateSequence() + */ + public CreateSequence newCreateSequence() + { + return new CreateSequenceImpl(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newCreateSequenceResponse() + */ + public CreateSequenceResponse newCreateSequenceResponse() + { + return new CreateSequenceResponseImpl(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newSequence() + */ + public Sequence newSequence() + { + return new SequenceImpl(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newSequenceAcknowledgement() + */ + public SequenceAcknowledgement newSequenceAcknowledgement() + { + return new SequenceAcknowledgementImpl(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newSequenceFault() + */ + public SequenceFault newSequenceFault() + { + return new SequenceFaultImpl(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newTerminateSequence() + */ + public TerminateSequence newTerminateSequence() + { + return new TerminateSequenceImpl(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.MessageFactory#newTerminateSequenceResponse() + */ + public TerminateSequenceResponse newTerminateSequenceResponse() + { + return new TerminateSequenceResponseImpl(); + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/MessageFactoryImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,65 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.MessageFactory; +import org.jboss.ws.extensions.wsrm.spi.Provider; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.Provider + */ +public final class ProviderImpl extends Provider +{ + + static final String IMPLEMENTATION_VERSION = "http://docs.oasis-open.org/ws-rx/wsrm/200702"; + private static final Provider INSTANCE = new ProviderImpl(); + + private ProviderImpl() + { + // forbidden inheritance + } + + public static Provider getInstance() + { + return INSTANCE; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.Provider#getMessageFactory() + */ + @Override + public final MessageFactory getMessageFactory() + { + return MessageFactoryImpl.getInstance(); + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.Provider#getNamespaceURI() + */ + @Override + public final String getNamespaceURI() + { + return IMPLEMENTATION_VERSION; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceAcknowledgementImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceAcknowledgementImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceAcknowledgementImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,158 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import java.util.List; + +import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement + */ +final class SequenceAcknowledgementImpl implements SequenceAcknowledgement +{ + + SequenceAcknowledgementImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#addAcknowledgementRange(org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement.AcknowledgementRange) + */ + public void addAcknowledgementRange(AcknowledgementRange acknowledgementRange) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#addNack(long) + */ + public void addNack(long messageNumber) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#getAcknowledgementRanges() + */ + public List<AcknowledgementRange> getAcknowledgementRanges() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#getIdentifier() + */ + public String getIdentifier() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#getNacks() + */ + public List<Long> getNacks() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#isFinal() + */ + public boolean isFinal() + { + // TODO Auto-generated method stub + return false; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#isNone() + */ + public boolean isNone() + { + // TODO Auto-generated method stub + return false; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#newAcknowledgementRange() + */ + public AcknowledgementRange newAcknowledgementRange() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#setFinal(boolean) + */ + public void setFinal(boolean isFinal) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#setIdentifier(java.lang.String) + */ + public void setIdentifier(String identifier) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement#setNone(boolean) + */ + public void setNone(boolean isNone) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceAcknowledgementImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceFaultImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceFaultImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceFaultImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,94 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFault; +import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFaultCode; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFault + */ +final class SequenceFaultImpl implements SequenceFault +{ + + SequenceFaultImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFault#getDetail() + */ + public Exception getDetail() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFault#getFaultCode() + */ + public SequenceFaultCode getFaultCode() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFault#setDetail(java.lang.Exception) + */ + public void setDetail(Exception detail) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFault#setFaultCode(org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFaultCode) + */ + public void setFaultCode(SequenceFaultCode faultCode) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceFaultImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,111 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.protocol.Sequence; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.Sequence + */ +final class SequenceImpl implements Sequence +{ + + SequenceImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.Sequence#getIdentifier() + */ + public String getIdentifier() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.Sequence#getMessageNumber() + */ + public long getMessageNumber() + { + // TODO Auto-generated method stub + return 0; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.Sequence#isLastMessage() + */ + public boolean isLastMessage() + { + // TODO Auto-generated method stub + return false; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.Sequence#setIdentifier(java.lang.String) + */ + public void setIdentifier(String identifier) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.Sequence#setLastMessage(boolean) + */ + public void setLastMessage(boolean lastMessage) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.Sequence#setMessageNumber(long) + */ + public void setMessageNumber(long messageNumber) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/SequenceImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,93 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence + */ +final class TerminateSequenceImpl implements TerminateSequence +{ + + TerminateSequenceImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence#getIdentifier() + */ + public String getIdentifier() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence#getLastMsgNumber() + */ + public void getLastMsgNumber() + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence#setIdentifier(java.lang.String) + */ + public void setIdentifier(String identifier) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence#setLastMsgNumber(long) + */ + public void setLastMsgNumber(long lastMsgNumber) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceResponseImpl.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceResponseImpl.java (rev 0) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceResponseImpl.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -0,0 +1,75 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.ws.extensions.wsrm.spec200702; + +import org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequenceResponse; +import org.w3c.dom.Element; + +/* + * @author richard.opalka(a)jboss.com + * @see org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequenceResponse + */ +final class TerminateSequenceResponseImpl implements TerminateSequenceResponse +{ + + TerminateSequenceResponseImpl() + { + // allow inside package use only + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequenceResponse#getIdentifier() + */ + public String getIdentifier() + { + // TODO Auto-generated method stub + return null; + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequenceResponse#setIdentifier(java.lang.String) + */ + public void setIdentifier(String identifier) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#fromXML(org.w3c.dom.Element) + */ + public void fromXML(Element e) + { + // TODO Auto-generated method stub + + } + + /* + * @see org.jboss.ws.extensions.wsrm.spi.protocol.XMLSerializable#toXML() + */ + public Element toXML() + { + // TODO Auto-generated method stub + return null; + } + +} Property changes on: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/TerminateSequenceResponseImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Modified: stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/Provider.java =================================================================== --- stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/Provider.java 2007-09-03 09:31:45 UTC (rev 4510) +++ stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/Provider.java 2007-09-03 10:49:45 UTC (rev 4511) @@ -32,7 +32,7 @@ * Must be overriden in the subclasses * @param targetNamespace */ - protected Provider(String targetNamespace) + protected Provider() { }

16 years, 8 months

1
0
0 / 0

JBossWS SVN: r4510 - in stack/native/trunk: src/main/java/org/jboss/ws/extensions/eventing/mgmt and 3 other directories.

by jbossws-commits＠lists.jboss.org

Author: heiko.braun(a)jboss.com Date: 2007-09-03 05:31:45 -0400 (Mon, 03 Sep 2007) New Revision: 4510 Added: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSink.java stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSinkIF.java stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SystemStatus.java stack/native/trunk/src/test/resources/jaxws/samples/wseventing/Readme.txt Modified: stack/native/trunk/ant-import-tests/build-samples-jaxws.xml stack/native/trunk/src/main/java/org/jboss/ws/extensions/eventing/mgmt/Subscription.java stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SysmonTestCase.java stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SysmonUtil.java stack/native/trunk/src/test/resources/jaxws/samples/wseventing/WEB-INF/wsdl/sysmon.wsdl Log: Extend eventing samples suing a local EJB3 web service as event sink Modified: stack/native/trunk/ant-import-tests/build-samples-jaxws.xml =================================================================== --- stack/native/trunk/ant-import-tests/build-samples-jaxws.xml 2007-08-31 15:48:18 UTC (rev 4509) +++ stack/native/trunk/ant-import-tests/build-samples-jaxws.xml 2007-09-03 09:31:45 UTC (rev 4510) @@ -120,7 +120,7 @@  <war warfile="${tests.output.dir}/libs/jaxws-samples-wseventing.war" webxml="${tests.output.dir}/resources/jaxws/samples/wseventing/WEB-INF/web.xml"> <classes dir="${tests.output.dir}/classes"> - <include name="org/jboss/test/ws/jaxws/samples/wseventing/*.class"/> + <include name="org/jboss/test/ws/jaxws/samples/wseventing/Sysmon**.class"/> </classes> <webinf dir="${tests.output.dir}/resources/jaxws/samples/wseventing/WEB-INF"> <include name="wsdl/jboss-web.xml"/> @@ -130,6 +130,13 @@ <include name="wsdl/ws-addr.xsd"/> </webinf> </war> + + <jar destfile="${tests.output.dir}/libs/jaxws-samples-wseventing-sink.jar"> + <fileset dir="${tests.output.dir}/classes"> + <include name="org/jboss/test/ws/jaxws/samples/wseventing/EventSink*.class"/> + <include name="org/jboss/test/ws/jaxws/samples/wseventing/SystemStatus.class"/> + </fileset> + </jar>  <war warfile="${tests.output.dir}/libs/jaxws-samples-wssecurity-encrypt.war" webxml="${tests.output.dir}/resources/jaxws/samples/wssecurity/WEB-INF/web.xml"> Modified: stack/native/trunk/src/main/java/org/jboss/ws/extensions/eventing/mgmt/Subscription.java =================================================================== --- stack/native/trunk/src/main/java/org/jboss/ws/extensions/eventing/mgmt/Subscription.java 2007-08-31 15:48:18 UTC (rev 4509) +++ stack/native/trunk/src/main/java/org/jboss/ws/extensions/eventing/mgmt/Subscription.java 2007-09-03 09:31:45 UTC (rev 4510) @@ -41,6 +41,7 @@ import org.jboss.ws.extensions.eventing.EventingConstants; import org.jboss.ws.extensions.eventing.jaxws.AttributedURIType; import org.jboss.ws.extensions.eventing.jaxws.EndpointReferenceType; +import org.jboss.ws.Constants; import org.jboss.wsf.common.DOMWriter; import org.w3c.dom.Element; @@ -84,7 +85,7 @@ // notification elements need to declare their namespace locally StringBuilder sb = new StringBuilder(); - sb.append("<env:Envelope xmlns:env='http://www.w3.org/2003/05/soap-envelope' "); + sb.append("<env:Envelope xmlns:env='"+ Constants.NS_SOAP11_ENV+"' "); sb.append("xmlns:wse='").append(EventingConstants.NS_EVENTING).append("' "); sb.append("xmlns:wsa='").append(EventingConstants.NS_ADDRESSING).append("'>"); sb.append("<env:Header>"); Added: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSink.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSink.java (rev 0) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSink.java 2007-09-03 09:31:45 UTC (rev 4510) @@ -0,0 +1,40 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.test.ws.jaxws.samples.wseventing; + +import javax.ejb.Stateless; +import javax.jws.WebService; + +/** + * @author Heiko.Braun(a)jboss.com + * @version $Revision$ + */ +@Stateless +@WebService(name = "SampleEventSink", targetNamespace = "http://www.jboss.org/sysmon", endpointInterface = "org.jboss.test.ws.jaxws.samples.wseventing.EventSinkIF") +public class EventSink implements EventSinkIF +{ + + public void newNotification(SystemStatus status) + { + System.out.println("Recv new notification: " + status); + } +} Property changes on: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSink.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSinkIF.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSinkIF.java (rev 0) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSinkIF.java 2007-09-03 09:31:45 UTC (rev 4510) @@ -0,0 +1,38 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.test.ws.jaxws.samples.wseventing; + +import javax.jws.WebMethod; +import javax.jws.WebService; +import javax.ejb.Remote; + +/** + * @author Heiko.Braun(a)jboss.com + * @version $Revision$ + */ +@Remote +@WebService(name = "SampleEventSink", targetNamespace = "http://www.jboss.org/sysmon") +public interface EventSinkIF +{ + @WebMethod + void newNotification(SystemStatus status); +} Property changes on: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/EventSinkIF.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Modified: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SysmonTestCase.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SysmonTestCase.java 2007-08-31 15:48:18 UTC (rev 4509) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SysmonTestCase.java 2007-09-03 09:31:45 UTC (rev 4510) @@ -26,17 +26,20 @@ import java.io.File; import java.net.URISyntaxException; import java.net.URL; +import java.net.URI; import javax.xml.namespace.QName; import javax.xml.ws.BindingProvider; import javax.xml.ws.Service; import javax.xml.ws.addressing.AddressingProperties; +import javax.naming.InitialContext; import junit.framework.Test; import org.jboss.ws.core.StubExt; import org.jboss.ws.extensions.addressing.AddressingClientUtil; import org.jboss.ws.extensions.eventing.EventingConstants; +import org.jboss.ws.extensions.eventing.mgmt.EventDispatcher; import org.jboss.ws.extensions.eventing.jaxws.DeliveryType; import org.jboss.ws.extensions.eventing.jaxws.EventSourceEndpoint; import org.jboss.ws.extensions.eventing.jaxws.FilterType; @@ -47,6 +50,8 @@ import org.jboss.ws.extensions.eventing.jaxws.Unsubscribe; import org.jboss.wsf.test.JBossWSTest; import org.jboss.wsf.test.JBossWSTestSetup; +import org.jboss.wsf.common.DOMUtils; +import org.w3c.dom.Element; /** * Test the eventing example service. @@ -68,7 +73,7 @@ public static Test suite() { - return new JBossWSTestSetup(SysmonTestCase.class, "jaxws-samples-wseventing.war"); + return new JBossWSTestSetup(SysmonTestCase.class, "jaxws-samples-wseventing.war, jaxws-samples-wseventing-sink.jar"); } protected void setUp() throws Exception @@ -158,4 +163,36 @@ return subscriptionTicket; } + + public void testNotification() throws Exception { + + SubscribeResponse response = doSubscribe("/SystemStatus/HostName/text()='localhost'"); + assertNotNull(response); + + String notification = + "<sys:newNotification xmlns:sys=\"http://www.jboss.org/sysmon\">" + + " <arg0>" + + " <activeThreadCount>12</activeThreadCount>" + + " <freeMemory>60000</freeMemory>" + + " <hostAddress>localhost</hostAddress>" + + " <hostname>bigben</hostname>" + + " <maxMemory>120000</maxMemory>" + + " <time>2001-10-26T21:32:52</time>" + + " </arg0>" + + " </sys:newNotification>"; + + Element payload = DOMUtils.parse(notification); + try + { + InitialContext iniCtx = getInitialContext(); + EventDispatcher delegate = (EventDispatcher) + iniCtx.lookup(EventingConstants.DISPATCHER_JNDI_NAME); + delegate.dispatch(new URI("http://www.jboss.org/sysmon/SystemInfo"), payload); + Thread.sleep(3000); + } + catch (Exception e) + { + throw e; + } + } } Modified: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SysmonUtil.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SysmonUtil.java 2007-08-31 15:48:18 UTC (rev 4509) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SysmonUtil.java 2007-09-03 09:31:45 UTC (rev 4510) @@ -101,7 +101,7 @@ delivery.setMode(EventingConstants.getDeliveryPush().toString()); EndpointReferenceType notifyEPR = new EndpointReferenceType(); AttributedURIType attURI = new AttributedURIType(); - attURI.setValue("http://jboss.org"); + attURI.setValue("http://localhost:8080/jaxws-samples-wseventing-sink/EventSink"); notifyEPR.setAddress(attURI); delivery.setNotifyTo(notifyEPR); return delivery; Added: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SystemStatus.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SystemStatus.java (rev 0) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SystemStatus.java 2007-09-03 09:31:45 UTC (rev 4510) @@ -0,0 +1,108 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.test.ws.jaxws.samples.wseventing; + +import javax.xml.bind.annotation.XmlElement; +import javax.xml.bind.annotation.XmlRootElement; +import java.util.Date; + +/** + * @author Heiko.Braun(a)jboss.com + * @version $Revision$ + */ +@XmlRootElement(name="SystemStatus", namespace = "http://www.jboss.org/sysmon") +public class SystemStatus +{ + private Date time; + private String hostname; + private String hostAddress; + private int activeThreadCount; + private String freeMemory; + private String maxMemory; + + + public Date getTime() + { + return time; + } + + public void setTime(Date time) + { + this.time = time; + } + + public String getHostname() + { + return hostname; + } + + public void setHostname(String hostname) + { + this.hostname = hostname; + } + + public String getHostAddress() + { + return hostAddress; + } + + public void setHostAddress(String hostAddress) + { + this.hostAddress = hostAddress; + } + + public int getActiveThreadCount() + { + return activeThreadCount; + } + + public void setActiveThreadCount(int activeThreadCount) + { + this.activeThreadCount = activeThreadCount; + } + + public String getFreeMemory() + { + return freeMemory; + } + + public void setFreeMemory(String freeMemory) + { + this.freeMemory = freeMemory; + } + + public String getMaxMemory() + { + return maxMemory; + } + + public void setMaxMemory(String maxMemory) + { + this.maxMemory = maxMemory; + } + + + public String toString() + { + return "SystemStatus {hostname="+hostname+", freeMemory="+freeMemory+"}"; + } +} Property changes on: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/samples/wseventing/SystemStatus.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/trunk/src/test/resources/jaxws/samples/wseventing/Readme.txt =================================================================== --- stack/native/trunk/src/test/resources/jaxws/samples/wseventing/Readme.txt (rev 0) +++ stack/native/trunk/src/test/resources/jaxws/samples/wseventing/Readme.txt 2007-09-03 09:31:45 UTC (rev 4510) @@ -0,0 +1,31 @@ +A few things that are not so obvious when working with eventing: + +1.) In order to dispatch you'll need to know the wsa:Action the EventSink listens on. + It's required to build the wse:Delivery EPR. + The WS-Eventing impl. actualy uses a naming convention: + It takes the EventSourceNS and appends "/Notification" to it, i.e: + + EventDispatcher delegate = (EventDispatcher) iniCtx.lookup(EventingConstants.DISPATCHER_JNDI_NAME); + delegate.dispatch(new URI("http://www.jboss.org/sysmon/SystemInfo"), payload); + +2.) Where do it get the EventSourceNS from? + Answer: There is an MBean in place that allows browsing of the registered EventSources: + + jboss.ws:service=SubscriptionManager,module=eventing + + The 'showEventsourceTable()' dumps the EventSource names and namespaces. + +3.) I'll dispatch but never receive it at the sink. + Answer: You are probably using the wrong wse:Delivery EPR. + Take a look at the sample test case. The EPR is build like this: + + EndpointReferenceType notifyEPR = new EndpointReferenceType(); + AttributedURIType attURI = new AttributedURIType(); + attURI.setValue("http://localhost:8080/jaxws-samples-wseventing-sink/EventSink"); + notifyEPR.setAddress(attURI); + delivery.setNotifyTo(notifyEPR); + + Whereas 'http://localhost:8080/jaxws-samples-wseventing-sink/EventSink' is the event sink address + that's deployed as an EJB3 web service. + + \ No newline at end of file Property changes on: stack/native/trunk/src/test/resources/jaxws/samples/wseventing/Readme.txt ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Modified: stack/native/trunk/src/test/resources/jaxws/samples/wseventing/WEB-INF/wsdl/sysmon.wsdl =================================================================== --- stack/native/trunk/src/test/resources/jaxws/samples/wseventing/WEB-INF/wsdl/sysmon.wsdl 2007-08-31 15:48:18 UTC (rev 4509) +++ stack/native/trunk/src/test/resources/jaxws/samples/wseventing/WEB-INF/wsdl/sysmon.wsdl 2007-09-03 09:31:45 UTC (rev 4510) @@ -19,30 +19,37 @@ <xs:include schemaLocation='ws-eventing.xsd'/> </xs:schema> - <xs:schema - targetNamespace="http://www.jboss.org/sysmon" - elementFormDefault="qualified" - blockDefault="#all"> +  + <xs:schema targetNamespace='http://www.jboss.org/sysmon' version='1.0' xmlns:tns='http://www.jboss.org/sysmon' xmlns:xs='http://www.w3.org/2001/XMLSchema'> + <xs:element name='SystemStatus' type='tns:systemStatus'/> + <xs:element name='newNotification' type='tns:newNotification'/> - <xs:element name="SystemStatus"> - <xs:complexType> - <xs:sequence> - <xs:element name="Time " type="xs:dateTime"/> - <xs:element name="HostName" type="xs:string"/> - <xs:element name="HostAddress" type="xs:string"/> - <xs:element name="ActiveThreadCount" type="xs:int"/> - <xs:element name="FreeMemory" type="xs:string"/> - <xs:element name="MaxMemory" type="xs:string"/> - </xs:sequence> - </xs:complexType> - </xs:element> - - </xs:schema> + <xs:complexType name='newNotification'> + <xs:sequence> + <xs:element minOccurs='0' name='arg0' type='tns:systemStatus'/> + </xs:sequence> + </xs:complexType> + <xs:complexType name='systemStatus'> + <xs:sequence> + <xs:element name='activeThreadCount' type='xs:int'/> + <xs:element minOccurs='0' name='freeMemory' type='xs:string'/> + <xs:element minOccurs='0' name='hostAddress' type='xs:string'/> + <xs:element minOccurs='0' name='hostname' type='xs:string'/> + <xs:element minOccurs='0' name='maxMemory' type='xs:string'/> + + <xs:element minOccurs='0' name='time' type='xs:dateTime'/> + </xs:sequence> + </xs:complexType> + </xs:schema> + </wsdl:types> <wsdl:message name='SystemInfoMsg'> - <wsdl:part name='body' element='tns:SystemStatus'/> + <wsdl:part name='body' element='tns:newNotification'/> </wsdl:message> <wsdl:portType name='SystemInfo' wse:EventSource='true'>

16 years, 8 months

1
0
0 / 0

← Newer
1
...
12
13
14
15
Older →

Jump to page:

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

jbossws-commits September 2007