| commit | 310340c04ab76310b57d920dad5d938ecef9c895 | [log] [tgz] |
|---|---|---|
| author | tuteng <eguangning@gmail.com> | Wed Jul 10 15:36:51 2019 +0800 |
| committer | Sijie Guo <sijie@apache.org> | Wed Jul 10 00:36:51 2019 -0700 |
| tree | 9c9572191e90ea97f8ead5ada7750fc8d6f1352c | |
| parent | 823456463e47a1344aa9bb7c85a639be213d9e78 [diff] |
A preliminary version of spring-pulsar (#104)
* A preliminary version of spring-pulsar is implemented, include PulsarClient and Consumer. Because producer is not currently available, it has not been implemented for the time being.
PulsarClient reads the configuration from the file application.properties and then generates an instance. Use PulsarListener annotation to generate Consumer. Schema can be used.
One example:
```
@Service
public class PulsarEventReceive {
private static final Logger log = LoggerFactory.getLogger(PulsarEventReceive.class);
@PulsarListener(topic = "test", subscriptionName = "test")
public void receive(Message message) {
log.info("Received messages: {}", message);
}
}
```
Front end is based on vue-element-admin.
Back end is based on spring boot.