import javapns.notification.PushNotificationManager; //导入依赖的package包/类
public void push(PushNotificationProcessor processor) {
    Holder<PushNotificationManager> holder = null;
    boolean valid = true;
    try {
        logger.debug("try take PushNotificationManager from vibur pool");
        holder = pool.take();
        if (holder != null && holder.value() != null) {
            processor.process(holder.value());
        }
    } catch (Exception ex) {
        logger.error("push due to error", ex);
        valid = false;
    } finally {
        if (holder != null) {
            pool.restore(holder, valid);
        }
    }
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public PushNotificationManager borrowObject() {
    try {
        return super.borrowObject();
    } catch (Exception e) {
        logger.error("borrow object from pool due to error", e);
        throw new RuntimeException(e);
    }
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public void returnObject(PushNotificationManager manager) {
    try {
        super.returnObject(manager);
    } catch (Exception e) {
        logger.error("return manager to pool due to error, will invalidate it", e);
        invalidateObject(manager);
    }
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public void invalidateObject(PushNotificationManager manager) {
    try {
        super.invalidateObject(manager);
    } catch (Exception e) {
        logger.error("invalidate manager due to error", e);
    }
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public boolean validateObject(PushNotificationManager manager) {
    PushedNotification notification = null;
    try {
        notification = manager.sendNotification(new BasicDevice(RandomStringUtils.randomNumeric(64)),
                PushNotificationPayload.test());
    } catch (Exception e) {
        logger.error("validate manager:[{}] due to error:[{}]", manager, ExceptionUtils.getStackTrace(e));
    }
    return notification != null && notification.isSuccessful();
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
public PushNotificationTemplate(AppleNotificationServer appleNotificationServer) {
    this.pool = new ConcurrentHolderLinkedPool<PushNotificationManager>(
            new PushNotificationManagerCreator(appleNotificationServer),
            Runtime.getRuntime().availableProcessors(),
            Runtime.getRuntime().availableProcessors() * 4, false);

}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public boolean readyToTake(PushNotificationManager pushNotificationManager) {
    try {
        logger.debug("vibur readyToTake PushNotificationManager");
        pushNotificationManager.initializeConnection(appleNotificationServer);
        return true;
    } catch (Exception ex) {
        logger.warn("can not initialize PushNotificationManager", ex);
        return false;
    }
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public void destroy(PushNotificationManager pushNotificationManager) {
    try {
        logger.debug("vibur destroy PushNotificationManager");
        pushNotificationManager.stopConnection();
    } catch (Exception ex) {
        logger.warn("can not destroy PushNotificationManager", ex);
    }
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
public void push(PushNotificationProcessor processor) {
    PushNotificationManager manager = null;

    try {
        manager = pool.borrowObject();
        processor.process(manager);
        pool.returnObject(manager);
    } catch (Exception e) {
        logger.error("push due to error", e);

        if (manager != null) {
            pool.invalidateObject(manager);
        }
    }
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
private void push(final APNSPushTask event, final List<Device> devices) {
	int appId = event.getMessage().getAppId();
	final PushNotificationTemplate pushNotificationTemplate = templates.payloads.get(appId);
	if (pushNotificationTemplate == null) {
		logger.warn("can not find pushNotificationTemplate with appId:[{}], ignore event:[{}]", appId, event);
		return;
	}

	pushNotificationTemplate.push(new PushNotificationProcessor() {

		@Override
		public void process(PushNotificationManager manager) throws Exception {
			//int unread = timelineRepository.unread(event.userId, event.message.appId) + 1;
			PushNotificationPayload payload = PushNotificationPayload.combined(event.message.title, 1, "default");

			for (Device device : devices) {
				if (device.token == null || device.token.length() != 64) {
					continue;
				}

				PushedNotification notification = manager.sendNotification(new BasicDevice(device.token), payload,
						false);

				if (notification != null) {
					logger.debug(
							"push message:[{}] to apns[user/device]:[{}/{}], the acknowledge is:[{}], the push result is:{}",
							event.message.title,
							device.userId,
							device.token,
							notification,
							notification.isSuccessful());
				}
			}

		}
	});
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public PushNotificationManager makeObject() throws Exception {
    PushNotificationManager manager = new PushNotificationManager();
    manager.initializeConnection(appleNotificationServer);
    return manager;
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public void destroyObject(PushNotificationManager manager) throws Exception {
    manager.stopConnection();
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public PushNotificationManager create() {
    logger.debug("vibur create PushNotificationManager");
    return new PushNotificationManager();
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
@Override
public boolean readyToRestore(PushNotificationManager pushNotificationManager) {
    logger.debug("vibur readyToRestore PushNotificationManager");
    return true;
}
 

import javapns.notification.PushNotificationManager; //导入依赖的package包/类
void process(PushNotificationManager manager) throws Exception;