You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by hi...@apache.org on 2010/05/05 11:13:34 UTC
svn commit: r941211 -
/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/builders/MessageBuilderTest.java
Author: hiranya
Date: Wed May 5 09:13:33 2010
New Revision: 941211
URL: http://svn.apache.org/viewvc?rev=941211&view=rev
Log:
More eventing tests
Modified:
synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/builders/MessageBuilderTest.java
Modified: synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/builders/MessageBuilderTest.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/builders/MessageBuilderTest.java?rev=941211&r1=941210&r2=941211&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/builders/MessageBuilderTest.java (original)
+++ synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/eventing/builders/MessageBuilderTest.java Wed May 5 09:13:33 2010
@@ -80,6 +80,9 @@ public class MessageBuilderTest extends
assertEquals(filterDialect, sub.getFilterDialect());
assertEquals(filter, sub.getFilterValue());
assertEquals(date, sub.getExpires().getTime());
+ assertNull(SubscriptionMessageBuilder.getErrorCode());
+ assertNull(SubscriptionMessageBuilder.getErrorReason());
+ assertNull(SubscriptionMessageBuilder.getErrorSubCode());
} catch (Exception e) {
fail("Error while constructing the sample subscription request: " + e.getMessage());
}
@@ -87,23 +90,51 @@ public class MessageBuilderTest extends
public void testSubscriptionMessageBuilderScenarioTwo() {
String addressUrl = "http://synapse.test.com/eventing/subscriptions";
- String id = UUIDGenerator.getUUID();
String message = "<wse:Unsubscribe xmlns:wse=\"http://schemas.xmlsoap.org/ws/2004/08/eventing\"/>";
try {
MessageContext msgCtx = TestUtils.getAxis2MessageContext(message, null).
getAxis2MessageContext();
msgCtx.setTo(new EndpointReference(addressUrl));
- SOAPEnvelope env = msgCtx.getEnvelope();
- SOAPHeaderBlock header = env.getHeader().addHeaderBlock(
- EventingConstants.WSE_EN_IDENTIFIER,
- OMAbstractFactory.getSOAP11Factory().
- createOMNamespace(EventingConstants.WSE_EVENTING_NS, "wse"));
- header.setText(id);
+ String id = addIdentifierHeader(msgCtx);
SynapseSubscription sub = SubscriptionMessageBuilder.createUnSubscribeMessage(msgCtx);
assertEquals(id, sub.getId());
assertEquals(addressUrl, sub.getAddressUrl());
+ assertNull(SubscriptionMessageBuilder.getErrorCode());
+ assertNull(SubscriptionMessageBuilder.getErrorReason());
+ assertNull(SubscriptionMessageBuilder.getErrorSubCode());
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ fail("Error while constructing the sample subscription request: " + e.getMessage());
+ }
+ }
+
+ public void testSubscriptionMessageBuilderScenarioThree() {
+ String addressUrl = "http://synapse.test.com/eventing/subscriptions";
+ Date date = new Date(System.currentTimeMillis() + 3600000);
+ Calendar cal = Calendar.getInstance();
+ cal.setTime(date);
+
+ String message =
+ "<wse:Renew xmlns:wse=\"http://schemas.xmlsoap.org/ws/2004/08/eventing\">\n" +
+ " <wse:Expires>" + ConverterUtil.convertToString(cal) + "</wse:Expires>\n" +
+ "</wse:Renew>";
+ try {
+ MessageContext msgCtx = TestUtils.getAxis2MessageContext(message, null).
+ getAxis2MessageContext();
+ msgCtx.setTo(new EndpointReference(addressUrl));
+ String id = addIdentifierHeader(msgCtx);
+
+ SynapseSubscription sub = SubscriptionMessageBuilder.
+ createRenewSubscribeMessage(msgCtx);
+ assertEquals(id, sub.getId());
+ assertEquals(addressUrl, sub.getAddressUrl());
+ assertEquals(date, sub.getExpires().getTime());
+ assertNull(SubscriptionMessageBuilder.getErrorCode());
+ assertNull(SubscriptionMessageBuilder.getErrorReason());
+ assertNull(SubscriptionMessageBuilder.getErrorSubCode());
} catch (Exception e) {
e.printStackTrace();
@@ -111,5 +142,67 @@ public class MessageBuilderTest extends
}
}
+ public void testSubscriptionMessageBuilderScenarioFour() {
+ String addressUrl = "http://synapse.test.com/eventing/subscriptions";
+
+ String message =
+ "<wse:GetStatus xmlns:wse=\"http://schemas.xmlsoap.org/ws/2004/08/eventing\"/>";
+ try {
+ MessageContext msgCtx = TestUtils.getAxis2MessageContext(message, null).
+ getAxis2MessageContext();
+ msgCtx.setTo(new EndpointReference(addressUrl));
+ String id = addIdentifierHeader(msgCtx);
+
+ SynapseSubscription sub = SubscriptionMessageBuilder.createGetStatusMessage(msgCtx);
+ assertEquals(id, sub.getId());
+ assertEquals(addressUrl, sub.getAddressUrl());
+ assertNull(SubscriptionMessageBuilder.getErrorCode());
+ assertNull(SubscriptionMessageBuilder.getErrorReason());
+ assertNull(SubscriptionMessageBuilder.getErrorSubCode());
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ fail("Error while constructing the sample subscription request: " + e.getMessage());
+ }
+ }
+
+ public void testSubscriptionMessageBuilderScenarioFive() {
+ String addressUrl = "http://synapse.test.com/eventing/subscriptions";
+
+ String message =
+ "<wse:Renew xmlns:wse=\"http://schemas.xmlsoap.org/ws/2004/08/eventing\">\n" +
+ " <wse:Expires>2004-06-26T21:07:00.000-08:00</wse:Expires>\n" +
+ "</wse:Renew>";
+ try {
+ MessageContext msgCtx = TestUtils.getAxis2MessageContext(message, null).
+ getAxis2MessageContext();
+ msgCtx.setTo(new EndpointReference(addressUrl));
+ String id = addIdentifierHeader(msgCtx);
+
+ SynapseSubscription sub = SubscriptionMessageBuilder.
+ createRenewSubscribeMessage(msgCtx);
+ assertNull(id, sub.getId());
+ assertEquals(addressUrl, sub.getAddressUrl());
+ assertNotNull(SubscriptionMessageBuilder.getErrorCode());
+ assertNotNull(SubscriptionMessageBuilder.getErrorReason());
+ assertNotNull(SubscriptionMessageBuilder.getErrorSubCode());
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ fail("Error while constructing the sample subscription request: " + e.getMessage());
+ }
+ }
+
+ private String addIdentifierHeader(MessageContext msgCtx) {
+ String id = UUIDGenerator.getUUID();
+ SOAPEnvelope env = msgCtx.getEnvelope();
+ SOAPHeaderBlock header = env.getHeader().addHeaderBlock(
+ EventingConstants.WSE_EN_IDENTIFIER,
+ OMAbstractFactory.getSOAP11Factory().
+ createOMNamespace(EventingConstants.WSE_EVENTING_NS, "wse"));
+ header.setText(id);
+ return id;
+ }
+
}