em.close();
return;
}
// Add the subscription
Subscription subscription = new PersistentSubscription();
subscription.setSubscriber(from);
subscription.setTarget(to);
subscription.setCreated(Calendar.getInstance().getTime());
// Store
em.getTransaction().begin();
em.persist(subscription);
em.getTransaction().commit();