Mixing
Java Publisher Subscriber Design Pattern
Overview:
I am working on Java with Spring framework 4, one component of our application pulls some data in memory from db when the server is started. The other component inserts new data in db when required.
Problem Statement:
When data is inserted to db via second component, I want first component to know it so that it can refresh and update memory with newly updated data in db.
After googling a bit, I learned several approaches, but I am quite confused on what to choose. I am new to Java, in python we were able to execute this swiftly.
So, my question is there any library/framework in java which can do this swiftly?
java spring-mvc design-patterns publish-subscribe
edited Nov 26 '18 at 17:48
Karan Khanna
620628
asked Nov 20 '18 at 5:53
Chintan GotechaChintan Gotecha
92
add a comment |
Overview:
I am working on Java with Spring framework 4, one component of our application pulls some data in memory from db when the server is started. The other component inserts new data in db when required.
Problem Statement:
When data is inserted to db via second component, I want first component to know it so that it can refresh and update memory with newly updated data in db.
After googling a bit, I learned several approaches, but I am quite confused on what to choose. I am new to Java, in python we were able to execute this swiftly.
So, my question is there any library/framework in java which can do this swiftly?
java spring-mvc design-patterns publish-subscribe
edited Nov 26 '18 at 17:48
Karan Khanna
620628
asked Nov 20 '18 at 5:53
Chintan GotechaChintan Gotecha
92
add a comment |
Overview:
I am working on Java with Spring framework 4, one component of our application pulls some data in memory from db when the server is started. The other component inserts new data in db when required.
Problem Statement:
When data is inserted to db via second component, I want first component to know it so that it can refresh and update memory with newly updated data in db.
After googling a bit, I learned several approaches, but I am quite confused on what to choose. I am new to Java, in python we were able to execute this swiftly.
So, my question is there any library/framework in java which can do this swiftly?
java spring-mvc design-patterns publish-subscribe
edited Nov 26 '18 at 17:48
Karan Khanna
620628
asked Nov 20 '18 at 5:53
Chintan GotechaChintan Gotecha
92
Overview:
I am working on Java with Spring framework 4, one component of our application pulls some data in memory from db when the server is started. The other component inserts new data in db when required.
Problem Statement:
When data is inserted to db via second component, I want first component to know it so that it can refresh and update memory with newly updated data in db.
After googling a bit, I learned several approaches, but I am quite confused on what to choose. I am new to Java, in python we were able to execute this swiftly.
So, my question is there any library/framework in java which can do this swiftly?
java spring-mvc design-patterns publish-subscribe
java spring-mvc design-patterns publish-subscribe
edited Nov 26 '18 at 17:48
Karan Khanna
620628
asked Nov 20 '18 at 5:53
Chintan GotechaChintan Gotecha
92
edited Nov 26 '18 at 17:48
Karan Khanna
620628
asked Nov 20 '18 at 5:53
Chintan GotechaChintan Gotecha
92
edited Nov 26 '18 at 17:48
Karan Khanna
620628
edited Nov 26 '18 at 17:48
Karan Khanna
620628
edited Nov 26 '18 at 17:48
Karan Khanna
620628
620628
asked Nov 20 '18 at 5:53
Chintan GotechaChintan Gotecha
92
asked Nov 20 '18 at 5:53
Chintan GotechaChintan Gotecha
92
asked Nov 20 '18 at 5:53
Chintan GotechaChintan Gotecha
92
92
add a comment |
add a comment |
1 Answer
1
active
oldest
votes
You can use Observer design pattern for this.
Your ComponentA will have to register with ComponentB to be notified for an event when ComponentB performs any DB insert operation.
Start with the interface DBInsertListener which every class, that needs to be notified for the insert event in ComponentB, needs to implement.
public interface DBInsertListener
{
void process();
}
Now let the ComponentA which implements DBInsertListener register with ComponentB to be notified for any insert event.
public class ComponentA implements DBInsertListener
{
public void process() {
//your code here.
}
public ComponentA(final ComponentB componentB) {
componentB.registerToListenEvent(this);
}
}
At last, your ComponentB needs to provide a method for every DBInsertListener to register for listening to the insert event. It also needs to notify all the registered listeners when there is an insert operation.
public class ComponentB
{
List<DBInsertListener> dbInsertListeners = new ArrayList<>();
public void registerToListenEvent(final DBInsertListener dbInsertListener)
{
this.dbInsertListeners.add(dbInsertListener);
}
public void dbInsert()
{
//your code to insert data.
raiseEvent();
}
private void raiseEvent()
{
for (DBInsertListener dbInsertListener : dbInsertListeners)
{
dbInsertListener.process();
}
}
}
Hope this helps.
answered Nov 26 '18 at 16:11
Karan KhannaKaran Khanna
620628
add a comment |
Your Answer
StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");
StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});
function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});
}
});
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53387014%2fjava-publisher-subscriber-design-pattern%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
1 Answer
1
active
oldest
votes
1 Answer
1
active
oldest
votes
active
oldest
votes
active
oldest
votes
You can use Observer design pattern for this.
Your ComponentA will have to register with ComponentB to be notified for an event when ComponentB performs any DB insert operation.
Start with the interface DBInsertListener which every class, that needs to be notified for the insert event in ComponentB, needs to implement.
public interface DBInsertListener
{
void process();
}
Now let the ComponentA which implements DBInsertListener register with ComponentB to be notified for any insert event.
public class ComponentA implements DBInsertListener
{
public void process() {
//your code here.
}
public ComponentA(final ComponentB componentB) {
componentB.registerToListenEvent(this);
}
}
At last, your ComponentB needs to provide a method for every DBInsertListener to register for listening to the insert event. It also needs to notify all the registered listeners when there is an insert operation.
public class ComponentB
{
List<DBInsertListener> dbInsertListeners = new ArrayList<>();
public void registerToListenEvent(final DBInsertListener dbInsertListener)
{
this.dbInsertListeners.add(dbInsertListener);
}
public void dbInsert()
{
//your code to insert data.
raiseEvent();
}
private void raiseEvent()
{
for (DBInsertListener dbInsertListener : dbInsertListeners)
{
dbInsertListener.process();
}
}
}
Hope this helps.
answered Nov 26 '18 at 16:11
Karan KhannaKaran Khanna
620628
add a comment |
You can use Observer design pattern for this.
Your ComponentA will have to register with ComponentB to be notified for an event when ComponentB performs any DB insert operation.
Start with the interface DBInsertListener which every class, that needs to be notified for the insert event in ComponentB, needs to implement.
public interface DBInsertListener
{
void process();
}
Now let the ComponentA which implements DBInsertListener register with ComponentB to be notified for any insert event.
public class ComponentA implements DBInsertListener
{
public void process() {
//your code here.
}
public ComponentA(final ComponentB componentB) {
componentB.registerToListenEvent(this);
}
}
At last, your ComponentB needs to provide a method for every DBInsertListener to register for listening to the insert event. It also needs to notify all the registered listeners when there is an insert operation.
public class ComponentB
{
List<DBInsertListener> dbInsertListeners = new ArrayList<>();
public void registerToListenEvent(final DBInsertListener dbInsertListener)
{
this.dbInsertListeners.add(dbInsertListener);
}
public void dbInsert()
{
//your code to insert data.
raiseEvent();
}
private void raiseEvent()
{
for (DBInsertListener dbInsertListener : dbInsertListeners)
{
dbInsertListener.process();
}
}
}
Hope this helps.
answered Nov 26 '18 at 16:11
Karan KhannaKaran Khanna
620628
add a comment |
You can use Observer design pattern for this.
Your ComponentA will have to register with ComponentB to be notified for an event when ComponentB performs any DB insert operation.
Start with the interface DBInsertListener which every class, that needs to be notified for the insert event in ComponentB, needs to implement.
public interface DBInsertListener
{
void process();
}
Now let the ComponentA which implements DBInsertListener register with ComponentB to be notified for any insert event.
public class ComponentA implements DBInsertListener
{
public void process() {
//your code here.
}
public ComponentA(final ComponentB componentB) {
componentB.registerToListenEvent(this);
}
}
At last, your ComponentB needs to provide a method for every DBInsertListener to register for listening to the insert event. It also needs to notify all the registered listeners when there is an insert operation.
public class ComponentB
{
List<DBInsertListener> dbInsertListeners = new ArrayList<>();
public void registerToListenEvent(final DBInsertListener dbInsertListener)
{
this.dbInsertListeners.add(dbInsertListener);
}
public void dbInsert()
{
//your code to insert data.
raiseEvent();
}
private void raiseEvent()
{
for (DBInsertListener dbInsertListener : dbInsertListeners)
{
dbInsertListener.process();
}
}
}
Hope this helps.
answered Nov 26 '18 at 16:11
Karan KhannaKaran Khanna
620628
You can use Observer design pattern for this.
Your ComponentA will have to register with ComponentB to be notified for an event when ComponentB performs any DB insert operation.
Start with the interface DBInsertListener which every class, that needs to be notified for the insert event in ComponentB, needs to implement.
public interface DBInsertListener
{
void process();
}
Now let the ComponentA which implements DBInsertListener register with ComponentB to be notified for any insert event.
public class ComponentA implements DBInsertListener
{
public void process() {
//your code here.
}
public ComponentA(final ComponentB componentB) {
componentB.registerToListenEvent(this);
}
}
At last, your ComponentB needs to provide a method for every DBInsertListener to register for listening to the insert event. It also needs to notify all the registered listeners when there is an insert operation.
public class ComponentB
{
List<DBInsertListener> dbInsertListeners = new ArrayList<>();
public void registerToListenEvent(final DBInsertListener dbInsertListener)
{
this.dbInsertListeners.add(dbInsertListener);
}
public void dbInsert()
{
//your code to insert data.
raiseEvent();
}
private void raiseEvent()
{
for (DBInsertListener dbInsertListener : dbInsertListeners)
{
dbInsertListener.process();
}
}
}
Hope this helps.
answered Nov 26 '18 at 16:11
Karan KhannaKaran Khanna
620628
answered Nov 26 '18 at 16:11
Karan KhannaKaran Khanna
620628
answered Nov 26 '18 at 16:11
Karan KhannaKaran Khanna
620628
answered Nov 26 '18 at 16:11
Karan KhannaKaran Khanna
620628
620628
add a comment |
add a comment |
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53387014%2fjava-publisher-subscriber-design-pattern%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
