File tree 5 files changed +11
-6
lines changed
src/test/java/io/streamnative/pulsar/handlers/amqp/test/mock
5 files changed +11
-6
lines changed Original file line number Diff line number Diff line change 22
22
<parent >
23
23
<groupId >io.streamnative.pulsar.handlers</groupId >
24
24
<artifactId >pulsar-protocol-handler-amqp-parent</artifactId >
25
- <version >2.7.0.7 </version >
25
+ <version >2.7.0.8-rc-202102191415 </version >
26
26
</parent >
27
27
28
28
<groupId >io.streamnative.pulsar.handlers</groupId >
Original file line number Diff line number Diff line change @@ -123,8 +123,13 @@ public CompletableFuture<Void> deleteForcefully() {
123
123
return null ;
124
124
}
125
125
126
- @ Override public void expireMessages (int messageTTLInSeconds ) {
126
+ @ Override public boolean expireMessages (int messageTTLInSeconds ) {
127
+ return false ;
128
+ }
127
129
130
+ @ Override
131
+ public boolean expireMessages (Position position ) {
132
+ return false ;
128
133
}
129
134
130
135
@ Override public void redeliverUnacknowledgedMessages (Consumer consumer ) {
Original file line number Diff line number Diff line change 29
29
30
30
<groupId >io.streamnative.pulsar.handlers</groupId >
31
31
<artifactId >pulsar-protocol-handler-amqp-parent</artifactId >
32
- <version >2.7.0.7 </version >
32
+ <version >2.7.0.8-rc-202102191415 </version >
33
33
<name >StreamNative :: Pulsar Protocol Handler :: AoP Parent</name >
34
34
<description >Parent for AMQP on Pulsar implemented using Pulsar Protocol Handler.</description >
35
35
46
46
<log4j2 .version>2.13.3</log4j2 .version>
47
47
<lombok .version>1.18.4</lombok .version>
48
48
<mockito .version>2.22.0</mockito .version>
49
- <pulsar .version>2.7.0.7 </pulsar .version>
49
+ <pulsar .version>2.7.0.8-rc-202102191415 </pulsar .version>
50
50
<slf4j .version>1.7.25</slf4j .version>
51
51
<spotbugs-annotations .version>3.1.8</spotbugs-annotations .version>
52
52
<testcontainers .version>1.12.5</testcontainers .version>
Original file line number Diff line number Diff line change 20
20
<parent >
21
21
<groupId >io.streamnative.pulsar.handlers</groupId >
22
22
<artifactId >pulsar-protocol-handler-amqp-parent</artifactId >
23
- <version >2.7.0.7 </version >
23
+ <version >2.7.0.8-rc-202102191415 </version >
24
24
</parent >
25
25
<modelVersion >4.0.0</modelVersion >
26
26
Original file line number Diff line number Diff line change 22
22
<parent >
23
23
<groupId >io.streamnative.pulsar.handlers</groupId >
24
24
<artifactId >pulsar-protocol-handler-amqp-parent</artifactId >
25
- <version >2.7.0.7 </version >
25
+ <version >2.7.0.8-rc-202102191415 </version >
26
26
</parent >
27
27
28
28
<groupId >io.streamnative.pulsar.handlers</groupId >
You can’t perform that action at this time.
0 commit comments