mirror of
https://github.com/Athou/commafeed.git
synced 2026-03-21 21:37:29 +00:00
changing logging level
This commit is contained in:
@@ -38,7 +38,7 @@ public class SubscriptionHandler {
|
|||||||
publicUrl = publicUrl.substring(0, publicUrl.length() - 1);
|
publicUrl = publicUrl.substring(0, publicUrl.length() - 1);
|
||||||
}
|
}
|
||||||
|
|
||||||
log.info("sending new pubsub subscription to {} for {}", hub, topic);
|
log.debug("sending new pubsub subscription to {} for {}", hub, topic);
|
||||||
|
|
||||||
HttpPost post = new HttpPost(hub);
|
HttpPost post = new HttpPost(hub);
|
||||||
List<NameValuePair> nvp = Lists.newArrayList();
|
List<NameValuePair> nvp = Lists.newArrayList();
|
||||||
@@ -65,7 +65,7 @@ public class SubscriptionHandler {
|
|||||||
throw new Exception("Unexpected response code: " + code + " "
|
throw new Exception("Unexpected response code: " + code + " "
|
||||||
+ response.getStatusLine().getReasonPhrase());
|
+ response.getStatusLine().getReasonPhrase());
|
||||||
}
|
}
|
||||||
log.info("subscribed to {} for {}", hub, topic);
|
log.debug("subscribed to {} for {}", hub, topic);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("Could not subscribe to {} for {} : {}", hub, topic,
|
log.error("Could not subscribe to {} for {} : {}", hub, topic,
|
||||||
e.getMessage(), e);
|
e.getMessage(), e);
|
||||||
|
|||||||
@@ -57,13 +57,14 @@ public class PubSubHubbubCallbackREST {
|
|||||||
Preconditions.checkArgument(StringUtils.isNotEmpty(topic));
|
Preconditions.checkArgument(StringUtils.isNotEmpty(topic));
|
||||||
Preconditions.checkArgument("subscribe".equals(mode));
|
Preconditions.checkArgument("subscribe".equals(mode));
|
||||||
|
|
||||||
log.info("confirmation callback received for {}", topic);
|
log.debug("confirmation callback received for {}", topic);
|
||||||
|
|
||||||
List<FeedPushInfo> infos = feedPushInfoDAO.findByTopic(topic, false);
|
List<FeedPushInfo> infos = feedPushInfoDAO.findByTopic(topic, false);
|
||||||
|
|
||||||
if (infos.isEmpty() == false) {
|
if (infos.isEmpty() == false) {
|
||||||
for (FeedPushInfo info : infos) {
|
for (FeedPushInfo info : infos) {
|
||||||
log.info("activated push notifications for {}", info.getTopic());
|
log.debug("activated push notifications for {}",
|
||||||
|
info.getTopic());
|
||||||
info.setActive(true);
|
info.setActive(true);
|
||||||
}
|
}
|
||||||
feedPushInfoDAO.update(infos);
|
feedPushInfoDAO.update(infos);
|
||||||
@@ -83,7 +84,7 @@ public class PubSubHubbubCallbackREST {
|
|||||||
FetchedFeed fetchedFeed = parser.parse(null, bytes);
|
FetchedFeed fetchedFeed = parser.parse(null, bytes);
|
||||||
String topic = fetchedFeed.getTopic();
|
String topic = fetchedFeed.getTopic();
|
||||||
if (topic != null) {
|
if (topic != null) {
|
||||||
log.info("content callback received for {}", topic);
|
log.debug("content callback received for {}", topic);
|
||||||
List<FeedPushInfo> infos = feedPushInfoDAO.findByTopic(topic,
|
List<FeedPushInfo> infos = feedPushInfoDAO.findByTopic(topic,
|
||||||
true);
|
true);
|
||||||
for (FeedPushInfo info : infos) {
|
for (FeedPushInfo info : infos) {
|
||||||
|
|||||||
Reference in New Issue
Block a user