org.eclipse.californium.core.network.Endpoint.addInterceptor()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(7.1k)|赞(0)|评价(0)|浏览(141)

本文整理了Java中org.eclipse.californium.core.network.Endpoint.addInterceptor()方法的一些代码示例，展示了Endpoint.addInterceptor()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Endpoint.addInterceptor()方法的具体详情如下：
包路径：org.eclipse.californium.core.network.Endpoint
类名称：Endpoint
方法名：addInterceptor

Endpoint.addInterceptor介绍

[英]Adds a message interceptor to this endpoint.
[中]将消息侦听器添加到此终结点。

代码示例

代码示例来源：origin: eclipse/californium

  1. ep.addInterceptor(new MessageTracer());
  2. ep.addInterceptor(new OriginTracer());

代码示例来源：origin: eclipse/californium

  1. EndpointManager.getEndpointManager().getDefaultEndpoint().addInterceptor(new MessageTracer());

代码示例来源：origin: eclipse/californium

  1. ep.addInterceptor(new MessageTracer());

代码示例来源：origin: eclipse/californium

  1. @Before
  2. public void setupEndpoints() throws Exception {
  3.   //exchangeStore = new InMemoryMessageExchangeStore(CONFIG, new InMemoryRandomTokenProvider(CONFIG));
  4.   // bind to loopback address using an ephemeral port
  5. //	CoapEndpoint udpEndpoint = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), CONFIG, exchangeStore);
  6.   client = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), CONFIG);
  7.   client.addInterceptor(clientInterceptor);
  8.   client.addInterceptor(new MessageTracer());
  9.   client.start();
  10.   System.out.println("Client binds to port " + client.getAddress().getPort());
  11.   server = createLockstepEndpoint(client.getAddress());
  12. }

代码示例来源：origin: eclipse/californium

  1. @Before
  2. public void setupEndpoints() throws Exception {
  3.   client = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), config);
  4.   client.addInterceptor(clientInterceptor);
  5.   client.start();
  6.   System.out.println("Client binds to port " + client.getAddress().getPort());
  7.   server = createLockstepEndpoint(client.getAddress());
  8. }

代码示例来源：origin: eclipse/californium

  1. @Before
  2. public void setupServer() throws Exception {
  3.   System.out.println(System.lineSeparator() + "Start " + getClass().getSimpleName());
  4.   NetworkConfig config = network.createTestConfig()
  5.     .setInt(NetworkConfig.Keys.MAX_MESSAGE_SIZE, 128)
  6.     .setInt(NetworkConfig.Keys.PREFERRED_BLOCK_SIZE, 128)
  7.     .setInt(NetworkConfig.Keys.ACK_TIMEOUT, 200) // client retransmits after 200 ms
  8.     .setInt(NetworkConfig.Keys.ACK_RANDOM_FACTOR, 1);
  9.   client = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), config);
  10.   client.addInterceptor(new MessageTracer());
  11.   client.start();
  12.   clientPort = client.getAddress().getPort();
  13.   server = createLockstepEndpoint(client.getAddress());
  14.   System.out.println("Client binds to port " + clientPort);
  15. }

代码示例来源：origin: eclipse/californium

  1. @Before
  2. public void setupEndpoints() throws Exception {
  3.   testResource = new TestResource("test");
  4.   exchangeStore = new InMemoryMessageExchangeStore(CONFIG);
  5.   // bind to loopback address using an ephemeral port
  6.   CoapEndpoint udpEndpoint = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), CONFIG, exchangeStore);
  7.   server = new CoapServer();
  8.   server.addEndpoint(udpEndpoint);
  9.   server.add(testResource);
  10.   server.getEndpoints().get(0).addInterceptor(serverInterceptor);
  11.   server.start();
  12.   InetSocketAddress serverAddress = server.getEndpoints().get(0).getAddress();
  13.   System.out.println("Server binds to port " + serverAddress.getPort());
  14.   client = createLockstepEndpoint(serverAddress);
  15. }

代码示例来源：origin: eclipse/californium

  1. @BeforeClass
  2. public static void start() {
  3.   System.out.println(System.lineSeparator() + "Start " + ObserveServerSideTest.class.getSimpleName());
  4.   Logger ul = Logger.getLogger(UDPConnector.class.getName());
  5.   ul.setLevel(Level.OFF);
  6.   CONFIG = network.createTestConfig()
  7.       .setInt(NetworkConfig.Keys.ACK_TIMEOUT, ACK_TIMEOUT)
  8.       .setFloat(NetworkConfig.Keys.ACK_RANDOM_FACTOR, 1f)
  9.       .setFloat(NetworkConfig.Keys.ACK_TIMEOUT_SCALE, 1f)
  10.       .setInt(NetworkConfig.Keys.MAX_MESSAGE_SIZE, 32)
  11.       .setInt(NetworkConfig.Keys.PREFERRED_BLOCK_SIZE, 32);
  12.   testObsResource = new TestObserveResource(RESOURCE_PATH);
  13.   server = new CoapServer();
  14.   server.addEndpoint(new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), CONFIG));
  15.   server.add(testObsResource);
  16.   server.getEndpoints().get(0).addInterceptor(serverInterceptor);
  17.   server.start();
  18.   serverAddress = server.getEndpoints().get(0).getAddress();
  19.   System.out.println("Server binds to port " + serverAddress.getPort());
  20. }

代码示例来源：origin: eclipse/leshan

  1. public EventServlet(LeshanServer server, int securePort) {
  2.   server.getRegistrationService().addListener(this.registrationListener);
  3.   server.getObservationService().addListener(this.observationListener);
  4.   server.getPresenceService().addListener(this.presenceListener);
  5.   // add an interceptor to each endpoint to trace all CoAP messages
  6.   coapMessageTracer = new CoapMessageTracer(server.getRegistrationService());
  7.   for (Endpoint endpoint : server.coap().getServer().getEndpoints()) {
  8.     endpoint.addInterceptor(coapMessageTracer);
  9.   }
  10.   GsonBuilder gsonBuilder = new GsonBuilder();
  11.   gsonBuilder.registerTypeHierarchyAdapter(Registration.class,
  12.       new RegistrationSerializer(server.getPresenceService()));
  13.   gsonBuilder.registerTypeHierarchyAdapter(LwM2mNode.class, new LwM2mNodeSerializer());
  14.   gsonBuilder.setDateFormat("yyyy-MM-dd'T'HH:mm:ssXXX");
  15.   this.gson = gsonBuilder.create();
  16. }

代码示例来源：origin: eclipse/californium

  1. serverEndpoint.addInterceptor(interceptor);
  2. result.addEndpoint(serverEndpoint);
  3. result.add(new CoapResource(RESOURCE_TEST) {

代码示例来源：origin: eclipse/californium

  1. @BeforeClass
  2. public static void setupServer() throws Exception {
  3.   NetworkConfig config = network.getStandardTestConfig();
  4.   config.setString(NetworkConfig.Keys.DEDUPLICATOR, NetworkConfig.Keys.DEDUPLICATOR_MARK_AND_SWEEP);
  5.   config.setInt(NetworkConfig.Keys.MARK_AND_SWEEP_INTERVAL, DEDUPLICATOR_SWEEP_INTERVAL);
  6.   Endpoint ep = new CoapEndpoint(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), config);
  7.   ep.addInterceptor(new MessageTracer());
  8.   server = new CoapServer();
  9.   server.addEndpoint(ep);
  10.   server.add(new CoapResource(resourceName) {
  11.     @Override
  12.     public void handleGET(CoapExchange exchange) {
  13.       exchange.respond(payload);
  14.     }
  15.   });
  16.   server.start();
  17.   serverAddress = ep.getAddress();
  18. }

代码示例来源：origin: eclipse/californium

  1. @Test
  2. public void testObserveClient() throws Exception {
  3.   final AtomicInteger resetCounter = new AtomicInteger(0);
  4.   server.getEndpoints().get(0).addInterceptor(new ServerMessageInterceptor(resetCounter));
  5.   resourceX.setObserveType(Type.NON);
  6.   int repeat = 3;
  7.   CoapClient client = new CoapClient(uriX);
  8.   CountingHandler handler = new CountingHandler();
  9.   CoapObserveRelation rel = client.observeAndWait(handler);
  10.   // onLoad is called asynchronous to returning the response
  11.   // therefore wait for one onLoad
  12.   assertTrue(handler.waitForLoadCalls(1, 1000, TimeUnit.MILLISECONDS));
  13.   assertFalse("Response not received", rel.isCanceled());
  14.   assertNotNull("Response not received", rel.getCurrent());
  15.   assertEquals("\"resX says hi for the 1 time\"", rel.getCurrent().getResponseText());
  16.   rel.reactiveCancel();
  17.   System.out.println(uriX + " reactive canceled");
  18.   for (int i = 0; i < repeat; ++i) {
  19.     resourceX.changed("client");
  20.     Thread.sleep(50);
  21.   }
  22.   // still only one notification (the response) is received
  23.   assertFalse(handler.waitForLoadCalls(2, 1000, TimeUnit.MILLISECONDS));
  24.   assertEquals(repeat, resetCounter.get()); // repeat RST received
  25.   // no RST delivered (interceptor)
  26.   assertEquals(1, resourceX.getObserverCount());
  27. }

代码示例来源：origin: eclipse/californium

  1. EndpointManager.getEndpointManager().getDefaultEndpoint().addInterceptor(interceptor);

内容来源于网络，如有侵权，请联系作者删除！

Endpoint

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com