Title: [672] trunk/core/src/test/java/org/servicemix/jbi/messaging/MessageExchangeTest.java: Add test case for SM-116
- Revision
- 672
- Author
- gnt
- Date
- 2005-10-26 03:12:07 -0400 (Wed, 26 Oct 2005)
Log Message
Add test case for SM-116
Added Paths
Diff
Added: trunk/core/src/test/java/org/servicemix/jbi/messaging/MessageExchangeTest.java (671 => 672)
--- trunk/core/src/test/java/org/servicemix/jbi/messaging/MessageExchangeTest.java 2005-10-25 21:37:44 UTC (rev 671)
+++ trunk/core/src/test/java/org/servicemix/jbi/messaging/MessageExchangeTest.java 2005-10-26 07:12:07 UTC (rev 672)
@@ -0,0 +1,50 @@
+/**
+ *
+ * Copyright 2005 LogicBlaze, Inc. http://www.logicblaze.com
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ **/
+package org.servicemix.jbi.messaging;
+
+import java.io.IOException;
+import java.io.ObjectInput;
+
+import javax.jbi.messaging.ExchangeStatus;
+import javax.jbi.messaging.MessageExchange;
+
+import junit.framework.TestCase;
+
+public class MessageExchangeTest extends TestCase {
+
+ public static class TestMessageExchange extends MessageExchangeImpl {
+ public TestMessageExchange() {
+ super(new ExchangePacket(), STATES);
+ }
+ public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+ }
+ private static int[][] STATES = {
+ { CAN_CONSUMER + CAN_OWNER + CAN_SET_IN_MSG + CAN_SEND + CAN_SEND_SYNC + CAN_STATUS_ACTIVE, -1, -1, -1 },
+ };
+ }
+
+ public void testErrorStatus() throws Exception {
+ MessageExchange me = new TestMessageExchange();
+ assertEquals(ExchangeStatus.ACTIVE, me.getStatus());
+ assertNull(me.getError());
+ me.setError(new Exception());
+ assertEquals(ExchangeStatus.ERROR, me.getStatus());
+ assertNotNull(me.getError());
+ }
+
+}
