You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ve...@apache.org on 2008/07/26 22:32:33 UTC
svn commit: r680043 - in
/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener:
ListenerTestCase.java ListenerTestServer.java MockMessageReceiver.java
Author: veithen
Date: Sat Jul 26 13:32:33 2008
New Revision: 680043
URL: http://svn.apache.org/viewvc?rev=680043&view=rev
Log:
Commented out code introduced in revision 680041 and breaking the build.
Modified:
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestCase.java
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestServer.java
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/MockMessageReceiver.java
Modified: synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestCase.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestCase.java?rev=680043&r1=680042&r2=680043&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestCase.java (original)
+++ synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestCase.java Sat Jul 26 13:32:33 2008
@@ -103,7 +103,7 @@
MessageData messageData;
AxisConfiguration axisConfiguration = server.getAxisConfiguration();
axisConfiguration.addService(service);
- server.addErrorListener(messageReceiver);
+// server.addErrorListener(messageReceiver);
try {
sendMessage(sender, server.getEPR(service),
contentTypeMode == ContentTypeMode.TRANSPORT ? contentType : null);
@@ -113,7 +113,7 @@
}
}
finally {
- server.removeErrorListener(messageReceiver);
+// server.removeErrorListener(messageReceiver);
axisConfiguration.removeService(service.getName());
}
Modified: synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestServer.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestServer.java?rev=680043&r1=680042&r2=680043&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestServer.java (original)
+++ synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/ListenerTestServer.java Sat Jul 26 13:32:33 2008
@@ -27,8 +27,8 @@
import org.apache.axis2.engine.DispatchPhase;
import org.apache.axis2.transport.TransportListener;
import org.apache.synapse.transport.UtilsTransportServer;
-import org.apache.synapse.transport.base.event.TransportErrorListener;
-import org.apache.synapse.transport.base.event.TransportErrorSource;
+//import org.apache.synapse.transport.base.event.TransportErrorListener;
+//import org.apache.synapse.transport.base.event.TransportErrorSource;
public class ListenerTestServer extends UtilsTransportServer {
private final TransportListener listener;
@@ -54,17 +54,17 @@
dispatchPhase.addHandler(dispatcher);
}
- public void addErrorListener(TransportErrorListener listener) {
- if (listener instanceof TransportErrorSource) {
- ((TransportErrorSource)listener).addErrorListener(listener);
- }
- }
-
- public void removeErrorListener(TransportErrorListener listener) {
- if (listener instanceof TransportErrorSource) {
- ((TransportErrorSource)listener).removeErrorListener(listener);
- }
- }
+// public void addErrorListener(TransportErrorListener listener) {
+// if (listener instanceof TransportErrorSource) {
+// ((TransportErrorSource)listener).addErrorListener(listener);
+// }
+// }
+//
+// public void removeErrorListener(TransportErrorListener listener) {
+// if (listener instanceof TransportErrorSource) {
+// ((TransportErrorSource)listener).removeErrorListener(listener);
+// }
+// }
public String getEPR(AxisService service) throws AxisFault {
EndpointReference[] endpointReferences =
Modified: synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/MockMessageReceiver.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/MockMessageReceiver.java?rev=680043&r1=680042&r2=680043&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/MockMessageReceiver.java (original)
+++ synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/listener/MockMessageReceiver.java Sat Jul 26 13:32:33 2008
@@ -28,13 +28,13 @@
import org.apache.axis2.AxisFault;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.engine.MessageReceiver;
-import org.apache.synapse.transport.base.event.TransportError;
-import org.apache.synapse.transport.base.event.TransportErrorListener;
+//import org.apache.synapse.transport.base.event.TransportError;
+//import org.apache.synapse.transport.base.event.TransportErrorListener;
/**
* A mock message receiver that puts the message data in a queue.
*/
-public class MockMessageReceiver implements MessageReceiver, TransportErrorListener {
+public class MockMessageReceiver implements MessageReceiver /*, TransportErrorListener*/ {
private interface Event {
MessageData process() throws Throwable;
}
@@ -55,13 +55,13 @@
});
}
- public void error(final TransportError error) {
- queue.add(new Event() {
- public MessageData process() throws Throwable {
- throw error.getException();
- }
- });
- }
+// public void error(final TransportError error) {
+// queue.add(new Event() {
+// public MessageData process() throws Throwable {
+// throw error.getException();
+// }
+// });
+// }
public MessageData waitForMessage(long timeout, TimeUnit unit) throws Throwable {
Event event = queue.poll(timeout, unit);