You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by cm...@apache.org on 2012/04/11 22:14:42 UTC
svn commit: r1324975 - in
/camel/branches/camel-2.9.x/components/camel-jaxb/src:
main/java/org/apache/camel/converter/jaxb/JaxbDataFormat.java
test/java/org/apache/camel/converter/jaxb/JaxbDataFormatTest.java
Author: cmueller
Date: Wed Apr 11 20:14:42 2012
New Revision: 1324975
URL: http://svn.apache.org/viewvc?rev=1324975&view=rev
Log:
CAMEL-3776: Add pooling support for JAXB data format
Modified:
camel/branches/camel-2.9.x/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/JaxbDataFormat.java
camel/branches/camel-2.9.x/components/camel-jaxb/src/test/java/org/apache/camel/converter/jaxb/JaxbDataFormatTest.java
Modified: camel/branches/camel-2.9.x/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/JaxbDataFormat.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/JaxbDataFormat.java?rev=1324975&r1=1324974&r2=1324975&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/JaxbDataFormat.java (original)
+++ camel/branches/camel-2.9.x/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/JaxbDataFormat.java Wed Apr 11 20:14:42 2012
@@ -147,13 +147,13 @@ public class JaxbDataFormat extends Serv
} else {
source = new StreamSource(stream);
}
- answer = unmarshaller.unmarshal(source, partialClass);
+ answer = getUnmarshaller().unmarshal(source, partialClass);
} else {
if (needFiltering(exchange)) {
NonXmlFilterReader reader = createNonXmlFilterReader(exchange, stream);
- answer = unmarshaller.unmarshal(reader);
+ answer = getUnmarshaller().unmarshal(reader);
} else {
- answer = unmarshaller.unmarshal(stream);
+ answer = getUnmarshaller().unmarshal(stream);
}
}
} finally {
@@ -260,6 +260,10 @@ public class JaxbDataFormat extends Serv
this.camelContext = camelContext;
}
+ public Unmarshaller getUnmarshaller() {
+ return unmarshaller;
+ }
+
@Override
protected void doStart() throws Exception {
ObjectHelper.notNull(camelContext, "CamelContext");
Modified: camel/branches/camel-2.9.x/components/camel-jaxb/src/test/java/org/apache/camel/converter/jaxb/JaxbDataFormatTest.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/components/camel-jaxb/src/test/java/org/apache/camel/converter/jaxb/JaxbDataFormatTest.java?rev=1324975&r1=1324974&r2=1324975&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/components/camel-jaxb/src/test/java/org/apache/camel/converter/jaxb/JaxbDataFormatTest.java (original)
+++ camel/branches/camel-2.9.x/components/camel-jaxb/src/test/java/org/apache/camel/converter/jaxb/JaxbDataFormatTest.java Wed Apr 11 20:14:42 2012
@@ -28,7 +28,10 @@ import javax.xml.bind.Marshaller;
import javax.xml.bind.Unmarshaller;
import javax.xml.stream.XMLStreamException;
+import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
+import org.apache.camel.impl.DefaultCamelContext;
+import org.apache.camel.impl.DefaultExchange;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
@@ -46,126 +49,107 @@ import static org.mockito.Matchers.anySt
import static org.mockito.Matchers.argThat;
import static org.mockito.Matchers.isA;
import static org.mockito.Matchers.same;
-import static org.mockito.Mockito.doCallRealMethod;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.when;
+import static org.mockito.Mockito.*;
-@RunWith(MockitoJUnitRunner.class)
public class JaxbDataFormatTest {
+
private JaxbDataFormat jaxbDataFormat;
- @Mock
- private Exchange exchangeMock;
- @Mock
private Marshaller marshallerMock;
- @Mock
private JaxbDataFormat jaxbDataFormatMock;
- @Mock
- private JAXBContext jaxbContextMock;
- @Mock
private Unmarshaller unmarshallerMock;
-
+ private CamelContext camelContext;
@Before
- public void setUp() {
+ public void setUp() throws Exception {
+ camelContext = new DefaultCamelContext();
+
jaxbDataFormat = new JaxbDataFormat();
+ jaxbDataFormat.setCamelContext(camelContext);
+ jaxbDataFormat.doStart();
}
- @SuppressWarnings("unchecked")
@Test
public void testNeedFilteringDisabledFiltering() {
- // tests combinations of data format option and exchange property
- when(exchangeMock.getProperty(anyString(), anyObject(), any(Class.class)))
- .thenReturn(false);
+ jaxbDataFormat.setFilterNonXmlChars(false);
+ Exchange exchange = new DefaultExchange(camelContext);
- jaxbDataFormat.needFiltering(exchangeMock);
- verify(exchangeMock).getProperty(Exchange.FILTER_NON_XML_CHARS, false, Boolean.class);
+ assertFalse(jaxbDataFormat.needFiltering(exchange));
}
- @SuppressWarnings("unchecked")
@Test
public void testNeedFilteringEnabledFiltering() {
- when(exchangeMock.getProperty(anyString(), anyObject(), any(Class.class))).thenReturn(true);
jaxbDataFormat.setFilterNonXmlChars(true);
- jaxbDataFormat.needFiltering(exchangeMock);
- verify(exchangeMock).getProperty(Exchange.FILTER_NON_XML_CHARS, true, Boolean.class);
+ Exchange exchange = new DefaultExchange(camelContext);
+
+ assertTrue(jaxbDataFormat.needFiltering(exchange));
}
- @SuppressWarnings("unchecked")
@Test
public void testNeedFilteringTruePropagates() {
- // tests combinations of data format option and exchange property
- when(exchangeMock.getProperty(anyString(), anyObject(), any(Class.class)))
- .thenReturn(true);
+ Exchange exchange = new DefaultExchange(camelContext);
+ exchange.setProperty(Exchange.FILTER_NON_XML_CHARS, Boolean.TRUE);
- assertTrue("Expecting filtering here", jaxbDataFormat.needFiltering(exchangeMock));
+ assertTrue(jaxbDataFormat.needFiltering(exchange));
}
- @SuppressWarnings("unchecked")
@Test
public void testNeedFilteringFalsePropagates() {
- // tests combinations of data format option and exchange property
- when(exchangeMock.getProperty(anyString(), anyObject(), any(Class.class)))
- .thenReturn(false);
+ Exchange exchange = new DefaultExchange(camelContext);
+ exchange.setProperty(Exchange.FILTER_NON_XML_CHARS, Boolean.FALSE);
- assertFalse("Not expecting filtering here", jaxbDataFormat.needFiltering(exchangeMock));
+ assertFalse(jaxbDataFormat.needFiltering(exchange));
}
@Test
public void testMarshalFilteringDisabled() throws IOException, XMLStreamException, JAXBException {
- doCallRealMethod().when(jaxbDataFormatMock).marshal(any(Exchange.class), anyObject(),
- any(OutputStream.class), any(Marshaller.class));
- when(jaxbDataFormatMock.needFiltering(exchangeMock)).thenReturn(false);
+ jaxbDataFormat.setFilterNonXmlChars(false);
+
+ jaxbDataFormatMock = spy(jaxbDataFormat);
+ marshallerMock = mock(Marshaller.class);
Object graph = new Object();
OutputStream stream = new ByteArrayOutputStream();
+ jaxbDataFormatMock.marshal(new DefaultExchange(camelContext), graph, stream, marshallerMock);
- jaxbDataFormatMock.marshal(exchangeMock, graph, stream, marshallerMock);
verify(marshallerMock).marshal(same(graph), same(stream));
}
@Test
public void testMarshalFilteringEnabled() throws XMLStreamException, JAXBException {
- doCallRealMethod().when(jaxbDataFormatMock).marshal(any(Exchange.class), anyObject(),
- any(OutputStream.class), any(Marshaller.class));
- when(jaxbDataFormatMock.needFiltering(exchangeMock)).thenReturn(true);
+ jaxbDataFormat.setFilterNonXmlChars(true);
+
+ jaxbDataFormatMock = spy(jaxbDataFormat);
+ marshallerMock = mock(Marshaller.class);
Object graph = new Object();
- OutputStream stream = new ByteArrayOutputStream();
+ jaxbDataFormatMock.marshal(new DefaultExchange(camelContext), graph, new ByteArrayOutputStream(), marshallerMock);
- jaxbDataFormatMock.marshal(exchangeMock, graph, stream, marshallerMock);
verify(marshallerMock).marshal(same(graph), isA(FilteringXmlStreamWriter.class));
-
}
@Test
public void testUnmarshalFilteringDisabled() throws IOException, JAXBException {
- doCallRealMethod().when(jaxbDataFormatMock).unmarshal(any(Exchange.class),
- any(InputStream.class));
+ jaxbDataFormat.setFilterNonXmlChars(false);
- when(jaxbDataFormatMock.getContext()).thenReturn(jaxbContextMock);
- when(jaxbContextMock.createUnmarshaller()).thenReturn(unmarshallerMock);
+ jaxbDataFormatMock = spy(jaxbDataFormat);
+ unmarshallerMock = mock(Unmarshaller.class);
+ doReturn(unmarshallerMock).when(jaxbDataFormatMock).getUnmarshaller();
- when(jaxbDataFormatMock.needFiltering(exchangeMock)).thenReturn(false);
+ jaxbDataFormatMock.unmarshal(new DefaultExchange(camelContext), new ByteArrayInputStream(new byte[] {}));
- InputStream stream = new ByteArrayInputStream(new byte[] {});
-
- jaxbDataFormatMock.unmarshal(exchangeMock, stream);
verify(unmarshallerMock).unmarshal((InputStream) argThat(not(instanceOf(NonXmlFilterReader.class))));
}
@Test
public void testUnmarshalFilteringEnabled() throws IOException, JAXBException {
- doCallRealMethod().when(jaxbDataFormatMock).unmarshal(any(Exchange.class),
- any(InputStream.class));
-
- when(jaxbDataFormatMock.getContext()).thenReturn(jaxbContextMock);
- when(jaxbContextMock.createUnmarshaller()).thenReturn(unmarshallerMock);
+ jaxbDataFormat.setFilterNonXmlChars(true);
- when(jaxbDataFormatMock.needFiltering(exchangeMock)).thenReturn(true);
+ jaxbDataFormatMock = spy(jaxbDataFormat);
+ unmarshallerMock = mock(Unmarshaller.class);
+ doReturn(unmarshallerMock).when(jaxbDataFormatMock).getUnmarshaller();
- InputStream stream = new ByteArrayInputStream(new byte[] {});
+ jaxbDataFormatMock.unmarshal(new DefaultExchange(camelContext), new ByteArrayInputStream(new byte[] {}));
- jaxbDataFormatMock.unmarshal(exchangeMock, stream);
verify(unmarshallerMock).unmarshal(any(NonXmlFilterReader.class));
}