#115 - fixes compile issues (_republish currently not implemented).

incodehq · Oct 1, 2019 · 155d05a · 155d05a
1 parent d4df0e6
commit 155d05a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 30 deletions.
diff --git a/...rc/main/java/org/isisaddons/module/publishmq/dom/jdo/events/PublishedEvent_republish.java b/...rc/main/java/org/isisaddons/module/publishmq/dom/jdo/events/PublishedEvent_republish.java
@@ -2,10 +2,11 @@
 
 import javax.inject.Inject;
 
-import org.apache.isis.applib.annotation.*;
-import org.apache.isis.schema.ixn.v1.InteractionDto;
-import org.apache.isis.schema.utils.InteractionDtoUtils;
-
+import org.apache.isis.applib.annotation.Action;
+import org.apache.isis.applib.annotation.ActionLayout;
+import org.apache.isis.applib.annotation.MemberOrder;
+import org.apache.isis.applib.annotation.Mixin;
+import org.apache.isis.applib.annotation.SemanticsOf;
 import org.isisaddons.module.publishmq.PublishMqModule;
 import org.isisaddons.module.publishmq.dom.servicespi.PublisherServiceUsingActiveMq;
 
@@ -33,22 +34,7 @@ public static class ActionDomainEvent extends PublishMqModule.ActionDomainEvent<
     @MemberOrder(name = "transactionId", sequence = "1")
     public PublishedEvent $$() {
 
-        final String xml = publishedEvent.getSerializedForm();
-
-        final PublishedEventType eventType = publishedEvent.getEventType();
-        switch (eventType) {
-        case ACTION_INVOCATION:
-        case PROPERTY_EDIT:
-            final InteractionDto interactionDto = InteractionDtoUtils.fromXml(xml);
-            publisherService.republish(interactionDto);
-            break;
-        case CHANGED_OBJECTS:
-            break;
-        }
-        return publishedEvent;
+        throw new RuntimeException("Not yet implemented.");
     }
 
-    @Inject
-    PublisherServiceUsingActiveMq publisherService;
-
 }
diff --git a/...in/java/org/isisaddons/module/publishmq/dom/servicespi/PublisherServiceUsingActiveMq.java b/...in/java/org/isisaddons/module/publishmq/dom/servicespi/PublisherServiceUsingActiveMq.java
@@ -6,8 +6,6 @@
 import javax.annotation.PostConstruct;
 import javax.annotation.PreDestroy;
 import javax.inject.Inject;
-import javax.jms.JMSException;
-import javax.jms.Session;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -55,14 +53,6 @@ public void shutdown() {
     }
 
 
-    private static void closeSafely(Session session) {
-        try {
-            session.close();
-        } catch (JMSException e) {
-            // ignore
-        }
-    }
-
     //endregion
 
 
@@ -121,6 +111,7 @@ private void persist(final PublishedObjects publishedObjects) {
 
     @Inject
     List<InteractionExecutionRepository> interactionExecutionRepositories;
+
     //endregion
 
 }