distributed events and coordination for jgroups clusters in spring applications
Switch branches/tags
Clone or download
Pull request Compare This branch is 20 commits ahead of jeffskj:master.
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
src
.gitignore
.travis.yml
LICENSE
README.md
pom.xml

README.md

RopeTeam

distributed events and coordination for jgroups clusters in spring applications.

Features

  • Cluster member task limiting
  • Clustered Event Bus

Task Limiting

Limit a task or method call to one cluster member. This is useful for scheduled tasks that you only want running on one member. Ropeteam allows dynamic assignment of which cluster member runs a task. A task will stay assigned to the same member unless it dies, in which case it will failover to another host.

Example

@OncePerCluster
@Scheduled(fixedDelay=1000)
public void someScheduledTask() {
  // method will only actually be called on one host per cluster
  // the same host will always run the task unless it dies 
}

Clustered Event Bus

Publish events to all members of the cluster. Events can be any object that can be marshalled to JSON with Jackson.

Publishing Events

@Autowired
EventPublisher publisher;

public void generateEvent() {
   publisher.publish(new HelloEvent("greetings"));
}

Subscribing to Events

@EventSubscriber
public void handleHelloEvent(HelloEvent e) {
   System.out.println(e.getGreeting())
}

Get It

<dependency>
    <groupId>com.rei.ropeteam</groupId>
    <artifactId>ropeteam</artifactId>
    <version>1.0</version>
</dependency>

This project is a fork/rename of jeffskj/flock