consumer.setGroup(persistenceManager.getConsumerGroup(cgm.getName()));
}
for (RegistrationMapping rm : getRegistrations())
{
consumer.addRegistration(rm.toRegistration(consumer, persistenceManager));
}
}
catch (RegistrationException e)
{
throw new RuntimeException(e);