InvalidCacheEventConsumer (Alibaba RSocket Spring Boot Starter 1.1.4 API)

java.lang.Object
- com.alibaba.spring.boot.rsocket.InvalidCacheEventConsumer

All Implemented Interfaces:: CloudEventsConsumer

public class InvalidCacheEventConsumer
extends Object
implements CloudEventsConsumer

InvalidCacheEvent consumer

Author:: leijuan

Constructor Summary

Constructors
Constructor Description

InvalidCacheEventConsumer()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`reactor.core.publisher.Mono<Void>`	`accept(CloudEventImpl<?> cloudEvent)`
`boolean`	`shouldAccept(CloudEventImpl<?> cloudEvent)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail
- InvalidCacheEventConsumer
```
public InvalidCacheEventConsumer()
```

Method Detail

shouldAccept
```
public boolean shouldAccept(CloudEventImpl<?> cloudEvent)
```
Specified by:

shouldAccept in interface CloudEventsConsumer

accept

public reactor.core.publisher.Mono<Void> accept(CloudEventImpl<?> cloudEvent)

Specified by:: accept in interface CloudEventsConsumer