- public void handleReceive(Object message) throws Exception {
- if (message.getClass().equals(CloseDataChangeListenerRegistration.SERIALIZABLE_CLASS)) {
- closeListenerRegistration(
- new CloseDataChangeListenerRegistration());
+ public void handleReceive(Object message) {
+ if (message instanceof CloseDataChangeListenerRegistration) {
+ closeListenerRegistration();
+ } else {
+ unknownMessage(message);