Skip to content

Commit

Permalink
Rename AsyncApiProducer as AsyncApiDocProducer
Browse files Browse the repository at this point in the history
  • Loading branch information
Abdussamet KACI committed Jan 31, 2023
1 parent ebd06e0 commit e0d182b
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 10 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ maven { url = uri("https://jitpack.io") }
```

```
implementation("com.github.DogusTeknoloji:springkafkadoc:1.0.0")
implementation("com.github.DogusTeknoloji:springkafkadoc:1.0.1")
```

- Add asyncapi configuration file
Expand Down
4 changes: 2 additions & 2 deletions build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ plugins {
}

group = "com.dteknoloji"
version = "1.0.0"
version = "1.0.1"
java.sourceCompatibility = JavaVersion.VERSION_17
java.targetCompatibility = JavaVersion.VERSION_17

Expand All @@ -30,7 +30,7 @@ publishing {
publications {
create<MavenPublication>("maven") {
groupId = "com.dteknoloji"
version = "1.0.0"
version = "1.0.1"
artifactId = "springkafkadoc"
from(components["java"])
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import java.lang.annotation.Target

@Target(ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE)
@Retention(RetentionPolicy.RUNTIME)
annotation class AsyncApiProducer(
annotation class AsyncApiDocProducer(
val topicPattern: String = "",
val groupId: String = ""
)
Original file line number Diff line number Diff line change
Expand Up @@ -17,27 +17,27 @@ import java.lang.reflect.Method
class MethodLevelKafkaProducerScanner(
docket: AsyncApiDocket,
schemasService: SchemasService
) : AbstractProducerScanner<AsyncApiProducer>(docket, schemasService), ChannelsScanner, EmbeddedValueResolverAware {
) : AbstractProducerScanner<AsyncApiDocProducer>(docket, schemasService), ChannelsScanner, EmbeddedValueResolverAware {

private var resolver: StringValueResolver? = null

override fun setEmbeddedValueResolver(resolver: StringValueResolver) {
this.resolver = resolver
}

override fun getProducerAnnotationClass(): Class<AsyncApiProducer> {
return AsyncApiProducer::class.java
override fun getProducerAnnotationClass(): Class<AsyncApiDocProducer> {
return AsyncApiDocProducer::class.java
}

override fun getChannelName(annotation: AsyncApiProducer): String {
override fun getChannelName(annotation: AsyncApiDocProducer): String {
return annotation.topicPattern + "_subscribe"
}

override fun buildChannelBinding(annotation: AsyncApiProducer): Map<String, ChannelBinding?> {
override fun buildChannelBinding(annotation: AsyncApiDocProducer): Map<String, ChannelBinding?> {
return ImmutableMap.of("kafka", KafkaChannelBinding())
}

override fun buildOperationBinding(annotation: AsyncApiProducer): Map<String, OperationBinding> {
override fun buildOperationBinding(annotation: AsyncApiDocProducer): Map<String, OperationBinding> {
var groupId = resolver!!.resolveStringValue(annotation.groupId)
if (groupId == null || groupId.isEmpty()) {
groupId = null
Expand Down

0 comments on commit e0d182b

Please sign in to comment.