import com.notnoop.apns.EnhancedApnsNotification; //导入依赖的package包/类
@Test(timeout = 5000)
public void testProducerWithoutTokenHeader() throws Exception {
    String message = "Hello World";
    String messagePayload = APNS.newPayload().alertBody(message).build();

    EnhancedApnsNotification apnsNotification = new EnhancedApnsNotification(1, EnhancedApnsNotification.MAXIMUM_EXPIRY, FAKE_TOKEN, messagePayload);
    server.stopAt(apnsNotification.length());

    template.sendBody("direct:test", message);

    server.getMessages().acquire();
    assertArrayEquals(apnsNotification.marshall(), server.getReceived().toByteArray());
}
 

import com.notnoop.apns.EnhancedApnsNotification; //导入依赖的package包/类
@Test(timeout = 5000)
public void testProducer() throws Exception {
    String message = "Hello World";
    String messagePayload = APNS.newPayload().alertBody(message).build();

    EnhancedApnsNotification apnsNotification = new EnhancedApnsNotification(1, EnhancedApnsNotification.MAXIMUM_EXPIRY, FAKE_TOKEN, messagePayload);
    server.stopAt(apnsNotification.length());

    template.sendBody("direct:test", message);

    server.getMessages().acquire();
    assertArrayEquals(apnsNotification.marshall(), server.getReceived().toByteArray());
}
 

import com.notnoop.apns.EnhancedApnsNotification; //导入依赖的package包/类
@Test(timeout = 5000)
public void testProducerWithApnsNotification() throws InterruptedException {
    String message = "Hello World";
    String messagePayload = APNS.newPayload().alertBody(message).build();

    final EnhancedApnsNotification apnsNotification =
            new EnhancedApnsNotification(14, EnhancedApnsNotification.MAXIMUM_EXPIRY, FAKE_TOKEN, messagePayload);
    server.stopAt(apnsNotification.length());

    template.sendBody("direct:testWithApnsNotification", apnsNotification);

    server.getMessages().acquire();
    assertArrayEquals(apnsNotification.marshall(), server.getReceived().toByteArray());

}
 

import com.notnoop.apns.EnhancedApnsNotification; //导入依赖的package包/类
public Collection<EnhancedApnsNotification> push(Collection<String> deviceTokens, String payload) throws NetworkIOException {
    byte[] messageBytes = Utilities.toUTF8Bytes(payload);
    List<EnhancedApnsNotification> notifications = new ArrayList<EnhancedApnsNotification>(deviceTokens.size());
    for (String deviceToken : deviceTokens) {
        byte[] dtbytes = Utilities.decodeHex(deviceToken);
        EnhancedApnsNotification notification =
            new EnhancedApnsNotification(c.incrementAndGet(), EnhancedApnsNotification.MAXIMUM_EXPIRY, dtbytes, messageBytes);
        notifications.add(notification);
        push(notification);
    }
    return notifications;
}
 

import com.notnoop.apns.EnhancedApnsNotification; //导入依赖的package包/类
public Collection<EnhancedApnsNotification> push(Collection<String> deviceTokens, String payload) throws NetworkIOException {
    byte[] messageBytes = Utilities.toUTF8Bytes(payload);
    List<EnhancedApnsNotification> notifications = new ArrayList<EnhancedApnsNotification>(deviceTokens.size());
    for (String deviceToken : deviceTokens) {
        byte[] dtBytes = Utilities.decodeHex(deviceToken);
        EnhancedApnsNotification notification =
            new EnhancedApnsNotification(c.incrementAndGet(), EnhancedApnsNotification.MAXIMUM_EXPIRY, dtBytes, messageBytes);
        notifications.add(notification);
        push(notification);
    }
    return notifications;
}
 

import com.notnoop.apns.EnhancedApnsNotification; //导入依赖的package包/类
public void sendApnsNotification() {
	 String registrationId = "ab4fa0c794688dca7c149cbac1001ed2f451d02e4c55cc25be45e7693ad3aae3";
	 String message = "Hello";
	 ApnsServiceBuilder sb = APNS.newService();
	 
	 sb.withCert("/tmp/apns-dev.p12", "Enterprisy").withSandboxDestination();
	 
	 PayloadBuilder pb = APNS.newPayload();
	 pb.alertBody(message);
	 pb.sound("default");
	 pb.badge(1);
	 		 
	 sb.build().push(new EnhancedApnsNotification(1, 900, registrationId, pb.build()));
}
 

import com.notnoop.apns.EnhancedApnsNotification; //导入依赖的package包/类
@Test
public void testApnsProducer() throws Exception {
    CamelContext camelctx = new DefaultCamelContext();
    camelctx.addRoutes(new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            from("direct:start")
            .setHeader(HEADER_TOKENS, constant(FAKE_TOKEN))
            .to("apns:notify");
        }
    });

    int gatewayPort = getPortNumber("apns-feedback-port.txt");
    int feedbackPort = getPortNumber("apns-gateway-port.txt");

    ApnsServiceFactory apnsServiceFactory = ApnsUtils.createDefaultTestConfiguration(camelctx);
    apnsServiceFactory.setFeedbackHost("localhost");
    apnsServiceFactory.setFeedbackPort(gatewayPort);
    apnsServiceFactory.setGatewayHost("localhost");
    apnsServiceFactory.setGatewayPort(feedbackPort);

    ApnsService apnsService = apnsServiceFactory.getApnsService();
    ApnsComponent apnsComponent = new ApnsComponent(apnsService);
    camelctx.addComponent("apns", apnsComponent);

    camelctx.start();
    try {
        String message = "Hello World";
        String messagePayload = APNS.newPayload().alertBody(message).build();

        EnhancedApnsNotification apnsNotification = new EnhancedApnsNotification(1, EnhancedApnsNotification.MAXIMUM_EXPIRY, FAKE_TOKEN, messagePayload);
        server.stopAt(apnsNotification.length());

        ProducerTemplate template = camelctx.createProducerTemplate();
        template.sendBody("direct:start", message);

        server.getMessages().acquire();
        Assert.assertArrayEquals(apnsNotification.marshall(), server.getReceived().toByteArray());
    } finally {
        camelctx.stop();
    }
}