Skip to content
This repository has been archived by the owner on Jan 28, 2021. It is now read-only.

Commit

Permalink
#115 - adds OutboxEvent and PublishedEventAbstract (as common supercl…
Browse files Browse the repository at this point in the history 
…ass with PublshedEvent)
  • Loading branch information
@danhaywood
danhaywood committed Oct 3, 2019
1 parent f9f4a28 commit c256c1e
Show file tree
Hide file tree
Showing 3 changed files with 240 additions and 289 deletions.
17 changes: 17 additions & 0 deletions ...mq/impl/jdo/src/main/java/org/isisaddons/module/publishmq/dom/jdo/events/OutboxEvent.java
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
package org.isisaddons.module.publishmq.dom.jdo.events;

import org.apache.isis.applib.annotation.DomainObject;
import org.apache.isis.applib.annotation.DomainObjectLayout;
import org.apache.isis.applib.annotation.Editing;

@javax.jdo.annotations.PersistenceCapable(
schema = "isispublishmq",
table="OutboxEvent")
@DomainObject(
editing = Editing.DISABLED,
objectType = "isispublishmq.OutboxEvent"
)
@DomainObjectLayout(named = "Outbox Event")
public class OutboxEvent extends PublishedEventAbstract {

}
292 changes: 3 additions & 289 deletions ...impl/jdo/src/main/java/org/isisaddons/module/publishmq/dom/jdo/events/PublishedEvent.java
View file
Original file line number Diff line number Diff line change
@@ -1,38 +1,12 @@
package org.isisaddons.module.publishmq.dom.jdo.events;

import java.text.SimpleDateFormat;
import java.util.UUID;

import javax.jdo.annotations.IdentityType;

import org.apache.isis.applib.Identifier;
import org.apache.isis.applib.annotation.DomainObject;
import org.apache.isis.applib.annotation.DomainObjectLayout;
import org.apache.isis.applib.annotation.Editing;
import org.apache.isis.applib.annotation.Programmatic;
import org.apache.isis.applib.annotation.Property;
import org.apache.isis.applib.annotation.PropertyLayout;
import org.apache.isis.applib.annotation.Where;
import org.apache.isis.applib.services.HasTransactionId;
import org.apache.isis.applib.services.HasUsername;
import org.apache.isis.applib.services.RepresentsInteractionMemberExecution;
import org.apache.isis.applib.services.publish.EventType;
import org.apache.isis.applib.util.ObjectContracts;
import org.apache.isis.applib.util.TitleBuffer;
import org.apache.isis.objectstore.jdo.applib.service.DomainChangeJdoAbstract;
import org.apache.isis.objectstore.jdo.applib.service.JdoColumnLength;
import org.apache.isis.objectstore.jdo.applib.service.Util;

import org.isisaddons.module.publishmq.PublishMqModule;

import lombok.Getter;
import lombok.Setter;

@javax.jdo.annotations.PersistenceCapable(
identityType=IdentityType.APPLICATION,
schema = "isispublishmq",
table="PublishedEvent",
objectIdClass=PublishedEventPK.class)
table="PublishedEvent")
@javax.jdo.annotations.Queries( {
@javax.jdo.annotations.Query(
name="findByTransactionId", language="JDOQL",
Expand Down Expand Up @@ -117,268 +91,8 @@
editing = Editing.DISABLED,
objectType = "isispublishmq.PublishedEvent"
)
@DomainObjectLayout(
named = "Published Event"
)
public class PublishedEvent extends DomainChangeJdoAbstract implements HasTransactionId,
RepresentsInteractionMemberExecution, HasUsername {

//region > domain events
public static abstract class PropertyDomainEvent<T>
extends PublishMqModule.PropertyDomainEvent<PublishedEvent, T> {
}

public static abstract class CollectionDomainEvent<T>
extends PublishMqModule.CollectionDomainEvent<PublishedEvent, T> {
}

public static abstract class ActionDomainEvent
extends PublishMqModule.ActionDomainEvent<PublishedEvent> {
}
//endregion

//region > constructor, identification

public PublishedEvent() {
super(ChangeType.PUBLISHED_INTERACTION);
}
//endregion

//region > title
public String title() {

// nb: not thread-safe
// formats defined in https://docs.oracle.com/javase/7/docs/api/java/text/SimpleDateFormat.html
final SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm");

final TitleBuffer buf = new TitleBuffer();
buf.append(format.format(getTimestamp()));
buf.append(" ").append(getMemberIdentifier());
return buf.toString();
}
//endregion

//region > title (hidden property, unused)
public static class TitleDomainEvent extends PropertyDomainEvent<String> { }

@javax.jdo.annotations.Column(allowsNull="false", length=255, position = 9)
@Property(hidden = Where.EVERYWHERE)
@Getter @Setter
private String title;
//endregion

//region > user (property), getUsername()
public static class UserDomainEvent extends PropertyDomainEvent<String> { }

@javax.jdo.annotations.Column(allowsNull="false", length=50, position = 10)
@Property(
domainEvent = UserDomainEvent.class
)
@Getter @Setter
private String user;

@Override
@Programmatic
public String getUsername() {
return getUser();
}
//endregion

//region > timestamp (property)

public static class TimestampDomainEvent extends PropertyDomainEvent<java.sql.Timestamp> { }

@javax.jdo.annotations.Persistent
@javax.jdo.annotations.Column(allowsNull="false", position = 8)
@Property(
domainEvent = TimestampDomainEvent.class
)
@Getter @Setter
private java.sql.Timestamp timestamp;
//endregion

//region > transactionId (property)

public static class TransactionIdDomainEvent extends PropertyDomainEvent<UUID> {
}

/**
* The unique identifier (a GUID) of the transaction in which this published event was persisted.
*
* <p>
* The combination of ({@link #getTransactionId() transactionId}, {@link #getSequence() sequence}) makes up the
* primary key.
*/
@javax.jdo.annotations.PrimaryKey
@javax.jdo.annotations.Column(allowsNull="false",length=JdoColumnLength.TRANSACTION_ID, position = 0)
@Property(
domainEvent = TransactionIdDomainEvent.class
)
@PropertyLayout(
typicalLength = JdoColumnLength.TRANSACTION_ID
)
@Getter @Setter
private UUID transactionId;

//endregion

//region > sequence (property)

public static class SequenceDomainEvent extends PropertyDomainEvent<Integer> {
}

/**
* The 0-based additional identifier of a published event within the given {@link #getTransactionId() transaction}.
*
* <p>
* The combination of ({@link #getTransactionId() transactionId}, {@link #getSequence() sequence}) makes up the
* primary key.
*/
@javax.jdo.annotations.PrimaryKey
@javax.jdo.annotations.Column(position = 1)
@Property(
domainEvent = SequenceDomainEvent.class
)
@Getter @Setter
private int sequence;

//endregion

//region > eventType (property)

public static class EventTypeDomainEvent extends PropertyDomainEvent<EventType> {
}

@javax.jdo.annotations.Column(allowsNull="false", length=JdoColumnLength.PublishedEvent.EVENT_TYPE, position = 2)
@Property(
domainEvent = EventTypeDomainEvent.class
)
@Getter @Setter
private PublishedEventType eventType;
//endregion

//region > targetClass (property)

public static class TargetClassDomainEvent extends PropertyDomainEvent<String> { }

@javax.jdo.annotations.Column(allowsNull="true", length=JdoColumnLength.TARGET_CLASS, position = 6)
@Property(
domainEvent = TargetClassDomainEvent.class
)
@PropertyLayout(
named = "Class",
typicalLength = 30
)
@Getter
private String targetClass;

public void setTargetClass(final String targetClass) {
this.targetClass = Util.abbreviated(targetClass, JdoColumnLength.TARGET_CLASS);
}
//endregion

//region > targetAction (property)

public static class TargetActionDomainEvent extends PropertyDomainEvent<String> {
}

/**
* Only populated for {@link EventType#ACTION_INVOCATION}
*/
@javax.jdo.annotations.Column(allowsNull="true", length=JdoColumnLength.TARGET_ACTION, position = 5)
@Property(
domainEvent = TargetActionDomainEvent.class
)
@PropertyLayout(
named = "Action",
typicalLength = 30
)
@Getter
private String targetAction;

public void setTargetAction(final String targetAction) {
this.targetAction = Util.abbreviated(targetAction, JdoColumnLength.TARGET_ACTION);
}
//endregion

//region > targetStrDomain (property)

public static class TargetStrDomainEvent extends PropertyDomainEvent<String> {
}

@javax.jdo.annotations.Column(allowsNull="true", length=JdoColumnLength.BOOKMARK, name="target", position = 7)
@Property(
domainEvent = TargetStrDomainEvent.class
)
@PropertyLayout(
named = "Object"
)
@Getter @Setter
private String targetStr;

//endregion

//region > memberIdentifier (property)

public static class MemberIdentifierDomainEvent extends PropertyDomainEvent<String> {
}

/**
* Holds a string representation of the invoked action, equivalent to
* {@link Identifier#toClassAndNameIdentityString()}.
*
* <p>
* Only populated for {@link EventType#ACTION_INVOCATION},
* returns <tt>null</tt> otherwise.
*
* <p>
* This property is called 'memberIdentifier' rather than 'actionIdentifier' for
* consistency with other services (such as auditing and publishing) that may act on
* properties rather than simply just actions.
*/
@javax.jdo.annotations.Column(allowsNull="true", length=JdoColumnLength.MEMBER_IDENTIFIER, position = 3)
@Property(
domainEvent = MemberIdentifierDomainEvent.class
)
@PropertyLayout(
hidden = Where.ALL_TABLES,
typicalLength = 60
)
@Getter
private String memberIdentifier;


public void setMemberIdentifier(final String actionIdentifier) {
this.memberIdentifier = Util.abbreviated(actionIdentifier, JdoColumnLength.MEMBER_IDENTIFIER);
}

//endregion

//region > serializedForm (property)

public static class SerializedFormDomainEvent extends PropertyDomainEvent<String> {
}

@javax.jdo.annotations.Column(allowsNull="true", jdbcType="CLOB", sqlType="LONGVARCHAR", position = 4)
@Property(
domainEvent = SerializedFormDomainEvent.class
)
@Getter @Setter
@PropertyLayout(
hidden = Where.ALL_TABLES,
multiLine = 14
)
private String serializedForm;

//endregion

//region > toString

@Override
public String toString() {
return ObjectContracts.toString(this, "timestamp","user","eventType","memberIdentifier");
}
//endregion
@DomainObjectLayout(named = "Published Event")
public class PublishedEvent extends PublishedEventAbstract {


}
Loading

0 comments on commit c256c1e

Please sign in to comment.