Skip to content

Commit 8349a06

Browse files
committed
Support stream offset specification in consumer builder
1 parent 2068268 commit 8349a06

File tree

386 files changed

+1872
-394
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

386 files changed

+1872
-394
lines changed

0.1.0-SNAPSHOT/api/allclasses-index.html

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>All Classes and Interfaces (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
@@ -115,6 +115,10 @@ <h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces<
115115
<div class="col-last even-row-color all-classes-table all-classes-table-tab1">&nbsp;</div>
116116
<div class="col-first odd-row-color all-classes-table all-classes-table-tab1"><a href="com/rabbitmq/client/amqp/ConsumerBuilder.html" title="interface in com.rabbitmq.client.amqp">ConsumerBuilder</a></div>
117117
<div class="col-last odd-row-color all-classes-table all-classes-table-tab1">&nbsp;</div>
118+
<div class="col-first even-row-color all-classes-table all-classes-table-tab3"><a href="com/rabbitmq/client/amqp/ConsumerBuilder.StreamOffsetSpecification.html" title="enum in com.rabbitmq.client.amqp">ConsumerBuilder.StreamOffsetSpecification</a></div>
119+
<div class="col-last even-row-color all-classes-table all-classes-table-tab3">&nbsp;</div>
120+
<div class="col-first odd-row-color all-classes-table all-classes-table-tab1"><a href="com/rabbitmq/client/amqp/ConsumerBuilder.StreamOptions.html" title="interface in com.rabbitmq.client.amqp">ConsumerBuilder.StreamOptions</a></div>
121+
<div class="col-last odd-row-color all-classes-table all-classes-table-tab1">&nbsp;</div>
118122
<div class="col-first even-row-color all-classes-table all-classes-table-tab1"><a href="com/rabbitmq/client/amqp/CredentialsProvider.html" title="interface in com.rabbitmq.client.amqp">CredentialsProvider</a></div>
119123
<div class="col-last even-row-color all-classes-table all-classes-table-tab1">&nbsp;</div>
120124
<div class="col-first odd-row-color all-classes-table all-classes-table-tab2"><a href="com/rabbitmq/client/amqp/observation/micrometer/DefaultProcessObservationConvention.html" title="class in com.rabbitmq.client.amqp.observation.micrometer">DefaultProcessObservationConvention</a></div>

0.1.0-SNAPSHOT/api/allpackages-index.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>All Packages (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/Address.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>Address (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/AddressBuilder.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>AddressBuilder (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/AmqpException.AmqpConnectionException.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>AmqpException.AmqpConnectionException (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/AmqpException.AmqpEntityDoesNotExistException.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>AmqpException.AmqpEntityDoesNotExistException (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/AmqpException.AmqpResourceClosedException.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>AmqpException.AmqpResourceClosedException (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/AmqpException.AmqpResourceInvalidStateException.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>AmqpException.AmqpResourceInvalidStateException (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/AmqpException.AmqpSecurityException.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>AmqpException.AmqpSecurityException (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/AmqpException.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>AmqpException (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/BackOffDelayPolicy.FixedBackOffDelayPolicy.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>BackOffDelayPolicy.FixedBackOffDelayPolicy (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/BackOffDelayPolicy.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>BackOffDelayPolicy (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/ByteCapacity.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>ByteCapacity (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/Connection.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>Connection (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/ConnectionBuilder.RecoveryConfiguration.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>ConnectionBuilder.RecoveryConfiguration (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/ConnectionBuilder.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>ConnectionBuilder (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/ConnectionSettings.TlsSettings.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>ConnectionSettings.TlsSettings (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/ConnectionSettings.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>ConnectionSettings (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/Consumer.Context.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>Consumer.Context (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/Consumer.MessageHandler.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>Consumer.MessageHandler (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0.1.0-SNAPSHOT/api/com/rabbitmq/client/amqp/Consumer.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (21) on Tue Jul 02 07:58:12 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Tue Jul 02 15:25:28 UTC 2024 -->
55
<title>Consumer (RabbitMQ AMQP 1.0 Java client 0.1.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

0 commit comments

Comments
 (0)