INT-1628: expose WireTap via @ManagedResource
This commit is contained in:
@@ -51,6 +51,14 @@ public class WireTapParserTests {
|
||||
assertEquals(original, intercepted);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void simpleWireTapWithId() {
|
||||
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
|
||||
"wireTapParserTests.xml", this.getClass());
|
||||
WireTap wireTap = (WireTap) context.getBean("wireTap");
|
||||
assertNotNull(wireTap);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void wireTapWithAcceptingSelector() {
|
||||
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
|
||||
@@ -98,7 +106,7 @@ public class WireTapParserTests {
|
||||
otherTimeoutCount++;
|
||||
}
|
||||
}
|
||||
assertEquals(3, defaultTimeoutCount);
|
||||
assertEquals(4, defaultTimeoutCount);
|
||||
assertEquals(1, expectedTimeoutCount);
|
||||
assertEquals(0, otherTimeoutCount);
|
||||
}
|
||||
|
||||
@@ -18,6 +18,13 @@
|
||||
</interceptors>
|
||||
</channel>
|
||||
|
||||
<channel id="withId">
|
||||
<queue capacity="10"/>
|
||||
<interceptors>
|
||||
<wire-tap id="wireTap" channel="wireTapChannel"/>
|
||||
</interceptors>
|
||||
</channel>
|
||||
|
||||
<channel id="accepting">
|
||||
<queue capacity="10"/>
|
||||
<interceptors>
|
||||
|
||||
Reference in New Issue
Block a user