Skip to content

Commit

Permalink
visibility
Browse files Browse the repository at this point in the history
  • Loading branch information
zeitlinger committed Aug 27, 2024
1 parent b05fd41 commit 70a2335
Show file tree
Hide file tree
Showing 13 changed files with 13 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import io.opentelemetry.api.trace.Span;
import javax.batch.api.chunk.listener.ChunkListener;

class CustomEventChunkListener implements ChunkListener {
public class CustomEventChunkListener implements ChunkListener {
@Override
public void beforeChunk() {
Span.current().addEvent("chunk.before");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import io.opentelemetry.api.trace.Span;
import javax.batch.api.chunk.listener.ItemProcessListener;

public class CustomEventItemProcessListener implements ItemProcessListener {
class CustomEventItemProcessListener implements ItemProcessListener {
@Override
public void beforeProcess(Object o) {
Span.current().addEvent("item.process.before");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import io.opentelemetry.api.trace.Span;
import javax.batch.api.chunk.listener.ItemReadListener;

public class CustomEventItemReadListener implements ItemReadListener {
class CustomEventItemReadListener implements ItemReadListener {
@Override
public void beforeRead() {
Span.current().addEvent("item.read.before");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import java.util.List;
import javax.batch.api.chunk.listener.ItemWriteListener;

public class CustomEventItemWriteListener implements ItemWriteListener {
class CustomEventItemWriteListener implements ItemWriteListener {
@Override
public void beforeWrite(List<Object> list) {
Span.current().addEvent("item.write.before");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import io.opentelemetry.api.trace.Span;
import javax.batch.api.listener.JobListener;

public class CustomEventJobListener implements JobListener {
class CustomEventJobListener implements JobListener {
@Override
public void beforeJob() {
Span.current().addEvent("job.before");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import io.opentelemetry.api.trace.Span;
import javax.batch.api.listener.StepListener;

public class CustomEventStepListener implements StepListener {
class CustomEventStepListener implements StepListener {
@Override
public void beforeStep() {
Span.current().addEvent("step.before");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import java.util.concurrent.atomic.AtomicReference;
import javax.batch.api.chunk.ItemReader;

public class SingleItemReader implements ItemReader {
class SingleItemReader implements ItemReader {
@Override
public void open(Serializable serializable) {}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import javax.batch.api.Batchlet;
import javax.inject.Inject;

public class TestBatchlet implements Batchlet {
class TestBatchlet implements Batchlet {
@Override
public String process() {
if (fail != null && Integer.valueOf(fail) == 1) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import javax.batch.api.Decider;
import javax.batch.runtime.StepExecution;

public class TestDecider implements Decider {
class TestDecider implements Decider {
@Override
public String decide(StepExecution[] stepExecutions) {
return "LEFT";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import javax.batch.api.chunk.ItemProcessor;
import org.codehaus.groovy.runtime.DefaultGroovyMethods;

public class TestItemProcessor implements ItemProcessor {
class TestItemProcessor implements ItemProcessor {
@Override
public Object processItem(Object item) {
return Integer.parseInt(DefaultGroovyMethods.asType(item, String.class));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
import java.util.stream.IntStream;
import javax.batch.api.chunk.ItemReader;

public class TestItemReader implements ItemReader {
class TestItemReader implements ItemReader {
@Override
public void open(Serializable serializable) {
itemsIt = items.iterator();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
import javax.batch.api.chunk.ItemWriter;
import org.codehaus.groovy.runtime.DefaultGroovyMethods;

public class TestItemWriter implements ItemWriter {
class TestItemWriter implements ItemWriter {
@Override
public void open(Serializable checkpoint) {}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
import javax.batch.api.chunk.ItemReader;
import javax.inject.Inject;

public class TestPartitionedItemReader implements ItemReader {
class TestPartitionedItemReader implements ItemReader {
@Override
public void open(Serializable checkpoint) {
start = Integer.parseInt(startStr);
Expand Down

0 comments on commit 70a2335

Please sign in to comment.