草庐IT

add_consumer

全部标签

java - Scala - Java 互操作 : can Scala emit enums in bytecode for Java to consume?

我有一个混合了Java/Scala的项目,它是使用Scala库的JavaGUI代码。有没有一种方法可以编写Scala代码,使其在编译时发出Java枚举?到目前为止,我尝试过的方法(密封案例类、扩展枚举)似乎生成了普通类,这使得从Java中使用它们比直接使用枚举要复杂得多。 最佳答案 为什么不能用Java编写enum类?混合源代码(即Java+Scala)项目是完全可行的... 关于java-Scala-Java互操作:canScalaemitenumsinbytecodeforJavat

java - Apache Camel : Aws-S3 consumer starts failing with connection pool timeout

我使用AWS-S3消费者定期轮询S3上特定位置的文件。在轮询一定次数后,它开始失败并出现给定的异常,Willtryagainatnextpoll.Causedby:[com.amazonaws.AmazonClientException-UnabletoexecuteHTTPrequest:Timeoutwaitingforconnectionfrompool]com.amazonaws.AmazonClientException:UnabletoexecuteHTTPrequest:Timeoutwaitingforconnectionfrompoolatcom.amazonaws.

java - 碧 Jade 报告 : How to add font not in the application classpath

我正在尝试使用一种字体,它没有安装在我的本地操作系统上,带有JasperReports。jasper报表是这样使用的:名为Corbel的字体被导出为字体扩展(使用iReport),并包含在我系统的文件夹中的文件(Corbel.jar)中。我使用如下代码将此扩展添加到应用程序的类路径中:ClassLoadercl=newURLClassLoader(newURL[]{newURL("file:///D:/path/to/Corbel_jar_folder/")});param=newHashMap();param.put(JRParameter.REPORT_CLASS_LOADER,c

java - 卡夫卡 : No message seen on console consumer after message sent by Java Producer

我是Kafka的新手。我在我的本地机器上创建了一个java生产者,并在网络上的另一台机器上设置了一个Kafka代理,比如M2(我可以ping、SSH、连接到这台机器)。在Eclipse控制台的生产者端,我收到“消息已发送”。但是当我检查机器M2上的控制台消费者时,我看不到这些消息。我的java生产者代码是:importorg.apache.kafka.clients.producer.KafkaProducer;importorg.apache.kafka.clients.producer.ProducerConfig;importorg.apache.kafka.clients.pr

Java & Spark : add unique incremental id to dataset

使用Spark和Java,我试图向现有的具有n列的数据集[行]添加一个整数标识列。我使用zipWithUniqueId()或zipWithIndex成功添加了一个id,甚至使用了monotonically_increasing_id()。但没有一个能令人满意。示例:我有一个包含195行的数据集。当我使用这三种方法中的一种时,我得到一些像1584156487或12036这样的ID。另外,这些ID不是连续的。我需要/想要的非常简单:一个Integerid列,其值从1到dataset.count()foreach行,其中id=1后跟id=2,等等。我如何在Java/Spark中做到这一点?

java - 亚马逊 SQS : The same message is consumed by two current consumers

我有四个当前消费者在AmazonAWS上收听同一个队列。从队列中拉取消息时,有时会出现同一条消息被两个不同的消费者消费的情况。请看下面的日志:18:01:46,515[jmsContainer-2]DEBUG-从队列中收到消息:ID:3698a927-930b-4d6a-aeca-f6692252879218:02:12,825[jmsContainer-3]DEBUG-从队列中收到消息:ID:3698a927-930b-4d6a-aeca-f66922528792我有一个包含4个并发使用者的JMS容器设置。我将可见性超时设置为30秒。既然container2收到了消息,怎么conta

java - Jar 文件 ADD DIRECTORY ENTRIES 导出 jar 时的 Eclipse 选项

我不知道我是否在问正确的问题,但想消除我的疑问。其实我遇到过从jar文件引用类文件的场景。我的意思是说我有一个后端java项目,比如ABC,里面有application-context.xml文件。现在我创建了ABC项目的jar文件并在一个基于Web的应用程序中使用。在这里,我遇到了bean没有Autowiring的问题,后来才知道问题是,我用Eclipse导出ABC项目的jar文件时,没有选择“ADDDIRECTORYENTRIES”复选框,后来我做了并且全部工作。只是为了查看通过在jar文件中选中此框进行了哪些更改,以便一切正常,所以我创建了2个jar文件,一个选中了“ADDDIR

Java:JTabbedPane 的 "Add Tab Button"

是否可以像在firefox中那样将按钮添加到选项卡式Pane。加号按钮就是我想要的。谢谢 最佳答案 我认为您应该能够通过构建自己的JTabbedPaneUI并使用setUI在JTabbedPane上设置它来管理它。您的ComponentUI具有获取可访问子项的方法。如果您指定了一个JButton和一个JLabel,那么您可能正在做生意。虽然我自己还没有尝试过。这是“风险自负”:) 关于Java:JTabbedPane的"AddTabButton",我们在StackOverflow上找到一

java - 是否有 Java-8 之前的功能接口(interface)可以替代 java.util.function.Consumer<T>?

为了迁移到Java8,我尝试以有利于使用lambda的方式编写我的代码。我需要一个功能接口(interface),该接口(interface)具有一个方法,该方法采用某种类型的一个参数T并返回void。这是java.util.function.Consumer的accept()方法的签名,但我当然还不能使用它。我可以使用标准Java7(最好是Java6)API中的另一个接口(interface)吗?我知道我可以创建自己的,但尤其是。在将此代码移植到Java8之前,如果我可以使用已经从标准Java6/7API中熟悉的标准接口(interface),那么可读性会更好。到目前为止我发现的最接

java - 在 add() 上丢失最旧元素的集合

我正在寻找一个实现Collection的Java类,并且当我add()一个新元素时丢失最旧的元素,如果元素总数大于X.是否存在或我必须自己实现?我需要一个线程安全的。 最佳答案 如果您正在寻找列表类型的解决方案,除了Linkedhasmap之外,GoogleGuava还有EvictingQueue.为了线程安全,您必须将其包装在同步包装器(Queues#synchronizedQueue)中。EvictingQueueq=EvictingQueue.create(3);QueuesyncQ=Queues.synchronizedQu