-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #193 from CJSCommonPlatform/change-jmx-bean-to-use…
…-strings Change command handlers to be called using Strings
- Loading branch information
Showing
90 changed files
with
660 additions
and
107 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
24 changes: 24 additions & 0 deletions
24
...ces/eventsourcing/publishedevent/rebuild/integration/helpers/DummySystemCommandStore.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,24 @@ | ||
package uk.gov.justice.services.eventsourcing.publishedevent.rebuild.integration.helpers; | ||
|
||
import uk.gov.justice.services.jmx.api.command.SystemCommand; | ||
import uk.gov.justice.services.jmx.command.SystemCommandHandlerProxy; | ||
import uk.gov.justice.services.jmx.command.SystemCommandStore; | ||
|
||
import java.util.List; | ||
|
||
import javax.enterprise.inject.Default; | ||
import javax.faces.bean.ApplicationScoped; | ||
|
||
@ApplicationScoped | ||
@Default | ||
public class DummySystemCommandStore implements SystemCommandStore { | ||
|
||
@Override | ||
public SystemCommandHandlerProxy findCommandProxy(final SystemCommand systemCommand) { | ||
throw new UnsupportedOperationException(); | ||
} | ||
|
||
@Override | ||
public void store(final List<SystemCommandHandlerProxy> systemCommandProxies) { | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2 changes: 1 addition & 1 deletion
2
...ices/event/sourcing/subscription/catchup/consumer/manager/EventStreamConsumerManager.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2 changes: 1 addition & 1 deletion
2
...ice/services/event/sourcing/subscription/catchup/consumer/task/ConsumeEventQueueTask.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2 changes: 1 addition & 1 deletion
2
...vices/event/sourcing/subscription/catchup/consumer/task/ConsumeEventQueueTaskFactory.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2 changes: 1 addition & 1 deletion
2
...vices/event/sourcing/subscription/catchup/consumer/task/ConsumeEventQueueTaskManager.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
22 changes: 22 additions & 0 deletions
22
event-store-management/event-store-management-commands/pom.xml
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,22 @@ | ||
<?xml version="1.0" encoding="UTF-8"?> | ||
<project xmlns="http://maven.apache.org/POM/4.0.0" | ||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" | ||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> | ||
<parent> | ||
<artifactId>event-store-management</artifactId> | ||
<groupId>uk.gov.justice.event-store</groupId> | ||
<version>2.2.8-SNAPSHOT</version> | ||
</parent> | ||
<modelVersion>4.0.0</modelVersion> | ||
|
||
<artifactId>event-store-management-commands</artifactId> | ||
|
||
<dependencies> | ||
<dependency> | ||
<groupId>uk.gov.justice.services</groupId> | ||
<artifactId>jmx-api</artifactId> | ||
<version>${framework.version}</version> | ||
</dependency> | ||
</dependencies> | ||
|
||
</project> |
13 changes: 13 additions & 0 deletions
13
...c/main/java/uk/gov/justice/services/eventstore/management/commands/AddTriggerCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
package uk.gov.justice.services.eventstore.management.commands; | ||
|
||
import uk.gov.justice.services.jmx.api.command.BaseSystemCommand; | ||
|
||
public class AddTriggerCommand extends BaseSystemCommand { | ||
|
||
public static final String ADD_TRIGGER = "ADD_TRIGGER"; | ||
private static final String DESCRIPTION = "Adds the 'queue_publish_event' trigger to the event log table so that new events inserted into the event_log table will trigger publishing."; | ||
|
||
public AddTriggerCommand() { | ||
super(ADD_TRIGGER, DESCRIPTION); | ||
} | ||
} |
13 changes: 13 additions & 0 deletions
13
.../src/main/java/uk/gov/justice/services/eventstore/management/commands/CatchupCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
package uk.gov.justice.services.eventstore.management.commands; | ||
|
||
import static uk.gov.justice.services.eventstore.management.commands.EventCatchupCommand.CATCHUP; | ||
|
||
import uk.gov.justice.services.jmx.api.command.SystemCommand; | ||
|
||
|
||
public interface CatchupCommand extends SystemCommand { | ||
|
||
default boolean isEventCatchup() { | ||
return CATCHUP.equals(getName()); | ||
} | ||
} |
13 changes: 13 additions & 0 deletions
13
...java/uk/gov/justice/services/eventstore/management/commands/DisablePublishingCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
package uk.gov.justice.services.eventstore.management.commands; | ||
|
||
import uk.gov.justice.services.jmx.api.command.BaseSystemCommand; | ||
|
||
public class DisablePublishingCommand extends BaseSystemCommand implements PublishingCommand { | ||
|
||
public static final String DISABLE_PUBLISHING = "DISABLE_PUBLISHING"; | ||
public static final String DESCRIPTION = "Disables the publishing of any newly received events"; | ||
|
||
public DisablePublishingCommand() { | ||
super(DISABLE_PUBLISHING, DESCRIPTION); | ||
} | ||
} |
13 changes: 13 additions & 0 deletions
13
.../java/uk/gov/justice/services/eventstore/management/commands/EnablePublishingCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
package uk.gov.justice.services.eventstore.management.commands; | ||
|
||
import uk.gov.justice.services.jmx.api.command.BaseSystemCommand; | ||
|
||
public class EnablePublishingCommand extends BaseSystemCommand implements PublishingCommand { | ||
|
||
public static final String ENABLE_PUBLISHING = "ENABLE_PUBLISHING"; | ||
public static final String DESCRIPTION = "Enables the publishing of any newly received events"; | ||
|
||
public EnablePublishingCommand() { | ||
super(ENABLE_PUBLISHING, DESCRIPTION); | ||
} | ||
} |
13 changes: 13 additions & 0 deletions
13
...main/java/uk/gov/justice/services/eventstore/management/commands/EventCatchupCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
package uk.gov.justice.services.eventstore.management.commands; | ||
|
||
import uk.gov.justice.services.jmx.api.command.BaseSystemCommand; | ||
|
||
public class EventCatchupCommand extends BaseSystemCommand implements CatchupCommand { | ||
|
||
public static final String CATCHUP = "CATCHUP"; | ||
private static final String DESCRIPTION = "Catches up and publishes all Events missing from the View Store"; | ||
|
||
public EventCatchupCommand() { | ||
super(CATCHUP, DESCRIPTION); | ||
} | ||
} |
13 changes: 13 additions & 0 deletions
13
...in/java/uk/gov/justice/services/eventstore/management/commands/IndexerCatchupCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
package uk.gov.justice.services.eventstore.management.commands; | ||
|
||
import uk.gov.justice.services.jmx.api.command.BaseSystemCommand; | ||
|
||
public class IndexerCatchupCommand extends BaseSystemCommand implements CatchupCommand { | ||
|
||
public static final String INDEXER_CATCHUP = "INDEXER_CATCHUP"; | ||
private static final String DESCRIPTION = "Rebuilds the application search indexes"; | ||
|
||
public IndexerCatchupCommand() { | ||
super(INDEXER_CATCHUP, DESCRIPTION); | ||
} | ||
} |
6 changes: 6 additions & 0 deletions
6
...c/main/java/uk/gov/justice/services/eventstore/management/commands/PublishingCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,6 @@ | ||
package uk.gov.justice.services.eventstore.management.commands; | ||
|
||
import uk.gov.justice.services.jmx.api.command.SystemCommand; | ||
|
||
public interface PublishingCommand extends SystemCommand { | ||
} |
13 changes: 13 additions & 0 deletions
13
.../src/main/java/uk/gov/justice/services/eventstore/management/commands/RebuildCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
package uk.gov.justice.services.eventstore.management.commands; | ||
|
||
import uk.gov.justice.services.jmx.api.command.BaseSystemCommand; | ||
|
||
public class RebuildCommand extends BaseSystemCommand { | ||
|
||
public static final String REBUILD = "REBUILD"; | ||
private static final String DESCRIPTION = "Rebuilds PublishedEvents and renumbers the Events"; | ||
|
||
public RebuildCommand() { | ||
super(REBUILD, DESCRIPTION); | ||
} | ||
} |
13 changes: 13 additions & 0 deletions
13
...ain/java/uk/gov/justice/services/eventstore/management/commands/RemoveTriggerCommand.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,13 @@ | ||
package uk.gov.justice.services.eventstore.management.commands; | ||
|
||
import uk.gov.justice.services.jmx.api.command.BaseSystemCommand; | ||
|
||
public class RemoveTriggerCommand extends BaseSystemCommand { | ||
|
||
public static final String REMOVE_TRIGGER = "REMOVE_TRIGGER"; | ||
private static final String DESCRIPTION = "Removes the 'queue_publish_event' trigger from the event log table so that new events inserted into the event_log table will no longer trigger publishing."; | ||
|
||
public RemoveTriggerCommand() { | ||
super(REMOVE_TRIGGER, DESCRIPTION); | ||
} | ||
} |
Oops, something went wrong.