You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2015/04/24 06:20:41 UTC
[2/2] camel git commit: CAMEL-8687 Fixed the build error
CAMEL-8687 Fixed the build error
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/6a1bfc63
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6a1bfc63
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6a1bfc63
Branch: refs/heads/camel-2.14.x
Commit: 6a1bfc63cdfc9961e7261bc7f01871cae8ff902c
Parents: 3e041ab
Author: Willem Jiang <wi...@gmail.com>
Authored: Fri Apr 24 12:19:22 2015 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Fri Apr 24 12:19:41 2015 +0800
----------------------------------------------------------------------
.../org/apache/camel/component/syslog/NettyRfc5425Test.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/6a1bfc63/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java
----------------------------------------------------------------------
diff --git a/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java b/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java
index 890842f..a795177 100644
--- a/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java
+++ b/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java
@@ -26,6 +26,7 @@ import org.apache.camel.impl.JndiRegistry;
import org.apache.camel.spi.DataFormat;
import org.apache.camel.test.AvailablePortFinder;
import org.apache.camel.test.junit4.CamelTestSupport;
+import org.jboss.netty.buffer.BigEndianHeapChannelBuffer;
import org.junit.BeforeClass;
import org.junit.Test;
@@ -67,12 +68,12 @@ public class NettyRfc5425Test extends CamelTestSupport {
assertMockEndpointsSatisfied();
}
-
+
@Test
public void testStructuredData() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:syslogReceiver");
mock.expectedMessageCount(1);
-
+
template.sendBody("direct:checkStructuredData", rfc5424WithStructuredData);
}
@@ -93,8 +94,8 @@ public class NettyRfc5425Test extends CamelTestSupport {
assertTrue(ex.getIn().getBody() instanceof SyslogMessage);
}
}).to("mock:syslogReceiver").marshal(syslogDataFormat).to("mock:syslogReceiver2");
-
-
+
+
from("direct:checkStructuredData").unmarshal(syslogDataFormat).process(new Processor() {
@Override
public void process(Exchange ex) {