From a6c3d4d239970810b979abd6bb4f00a206cf299d Mon Sep 17 00:00:00 2001 From: "Weston M. Price" Date: Thu, 3 May 2012 14:23:03 +0000 Subject: QPID-3878: QpidActivation should use connection per inbound listener Added ability to configure inbound listener multiplex behavior Added new property to ra.xml Updated README.txt to reflect changes Added Serialization unit tests for ActivationSpec and ResourceAdapter Contributions from Kevin Conner git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1333473 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/ra/QpidActivationSpecTest.java | 45 ++++++++++++++++++++++ .../apache/qpid/ra/QpidResourceAdapterTest.java | 13 +++++++ 2 files changed, 58 insertions(+) create mode 100644 qpid/java/jca/src/test/java/org/apache/qpid/ra/QpidActivationSpecTest.java (limited to 'qpid/java/jca/src/test') diff --git a/qpid/java/jca/src/test/java/org/apache/qpid/ra/QpidActivationSpecTest.java b/qpid/java/jca/src/test/java/org/apache/qpid/ra/QpidActivationSpecTest.java new file mode 100644 index 0000000000..e811427223 --- /dev/null +++ b/qpid/java/jca/src/test/java/org/apache/qpid/ra/QpidActivationSpecTest.java @@ -0,0 +1,45 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you 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.apache.qpid.ra; + +import java.io.ByteArrayOutputStream; +import java.io.ObjectOutputStream; + +import javax.resource.spi.ResourceAdapterInternalException; + +import org.apache.qpid.ra.inflow.QpidActivationSpec; + +import junit.framework.TestCase; + +public class QpidActivationSpecTest extends TestCase +{ + + public void testActivationSpecBasicSerialization() throws Exception + { + QpidActivationSpec spec = new QpidActivationSpec(); + ByteArrayOutputStream out = new ByteArrayOutputStream(); + ObjectOutputStream oos = new ObjectOutputStream(out); + oos.writeObject(spec); + oos.close(); + assertTrue(out.toByteArray().length > 0); + } + +} diff --git a/qpid/java/jca/src/test/java/org/apache/qpid/ra/QpidResourceAdapterTest.java b/qpid/java/jca/src/test/java/org/apache/qpid/ra/QpidResourceAdapterTest.java index ccad952d64..a6788a72c5 100644 --- a/qpid/java/jca/src/test/java/org/apache/qpid/ra/QpidResourceAdapterTest.java +++ b/qpid/java/jca/src/test/java/org/apache/qpid/ra/QpidResourceAdapterTest.java @@ -22,6 +22,9 @@ package org.apache.qpid.ra; import javax.resource.spi.ResourceAdapterInternalException; +import java.io.ByteArrayOutputStream; +import java.io.ObjectOutputStream; + import junit.framework.TestCase; @@ -62,4 +65,14 @@ public class QpidResourceAdapterTest extends TestCase } + public void testResourceAdapterBasicSerialization() throws Exception + { + + QpidResourceAdapter ra = new QpidResourceAdapter(); + ByteArrayOutputStream out = new ByteArrayOutputStream(); + ObjectOutputStream oos = new ObjectOutputStream(out); + oos.writeObject(ra); + oos.close(); + assertTrue(out.toByteArray().length > 0); + } } -- cgit v1.2.1