Skip to content

Commit

Permalink
DATAGO-75198 common code
Browse files Browse the repository at this point in the history
  • Loading branch information
rudraneel-chakraborty committed Jun 13, 2024
1 parent 23ad1cc commit da2c157
Show file tree
Hide file tree
Showing 7 changed files with 62 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package com.solace.maas.ep.common.messages;

import com.solace.maas.ep.common.model.EventBrokerResourceConfiguration;
import com.solace.maas.ep.event.management.agent.plugin.command.model.CommandBundle;
import com.solace.maas.ep.event.management.agent.plugin.command.model.JobStatus;
import com.solace.maas.ep.event.management.agent.plugin.mop.MOPMessage;
Expand All @@ -18,6 +19,7 @@ public class CommandMessage extends MOPMessage {
private String serviceId;
private JobStatus status;
private List<CommandBundle> commandBundles;
private List<EventBrokerResourceConfiguration> resources;

public CommandMessage() {
super();
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
package com.solace.maas.ep.common.model;


import lombok.Data;

@Data
public class EventBrokerAuthenticationConfiguration {
private String type;
private String protocol;
private EventBrokerCredentialConfiguration credential;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,13 @@
package com.solace.maas.ep.common.model;


import lombok.Data;

@Data
public class EventBrokerConnectionConfiguration {
private String msgVpn;
private String sempPageSize;
private EventBrokerAuthenticationConfiguration authentication;
private String name;
private String url;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
package com.solace.maas.ep.common.model;

import lombok.Data;

@Data
public class EventBrokerCredentialConfiguration {
private String userName;
private String password;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
package com.solace.maas.ep.common.model;

import lombok.Data;

import java.util.List;

@Data
public class EventBrokerResourceConfiguration extends ResourceConfiguration {
private String id;
private String brokerType;
private String name;
private List<EventBrokerConnectionConfiguration> connections;
private ResourceConfigurationType resourceConfigurationType;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,7 @@
package com.solace.maas.ep.common.model;

public abstract class ResourceConfiguration {

public abstract ResourceConfigurationType getResourceConfigurationType();

}
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
package com.solace.maas.ep.common.model;

public enum ResourceConfigurationType {
SOLACE,
KAFKA,
}

0 comments on commit da2c157

Please sign in to comment.